Method Publish
Publish(Message, DeliveryOption, Boolean)
This method is used to Publish the message in the cache with specified DeliveryOption. And the option to notify the publisher if the message has failed to deliver because of expiration, eviction or internal system issue.
Declaration
void Publish(Message message, DeliveryOption deliverOption, bool notifyDeliveryFailure = false)
Parameters
Type | Name | Description |
---|---|---|
Message | message | Message to be published |
DeliveryOption | deliverOption | Delivery Option |
System.Boolean | notifyDeliveryFailure | Is MessageDeliveryFailure event required for this message |
Examples
The following example demonstrates how to publish message on a topic.
First initialize cache.
ICache cache = CacheManager.GetCache("myCache");
Then get messaging service from cache.
IMessagingService messagingService=cache.MessagingService;
Then get topic from messagingService
ITopic topic=messagingService.GetTopic("mytopic");
if(topic==null) //If topic not exists create it.
{
topic=messagingService.CreateTopic("mytopic");
}
Then publish message on topic.
object payload = "mymessage";
Message message = new Message(payload); //creating message
topic.Publish(message, DeliveryOption.All);
Publish(Message, DeliveryOption, String, Boolean)
This method is used to Publish the message in the cache with specified DeliveryOption and SequenceName. Order of messages with same sequence name is retained. And the option to notify the publisher if the message has failed to deliver because of expiration, eviction or internal system issue.
Declaration
void Publish(Message message, DeliveryOption deliverOption, string sequenceName, bool notifyDeliveryFailure = false)
Parameters
Type | Name | Description |
---|---|---|
Message | message | Message to be published |
DeliveryOption | deliverOption | Delivery Option |
System.String | sequenceName | Sequence name of the message to be publsihed. The messages with same sequence name will be delivered in the same order as they are published. |
System.Boolean | notifyDeliveryFailure | Is MessageDeliveryFailure event required for this message |
Examples
The following example demonstrates how to publish message on a topic.
First initialize cache.
ICache cache = CacheManager.GetCache("myCache");
Then get messaging service from cache.
IMessagingService messagingService=cache.MessagingService;
Then get topic from messagingService
ITopic topic=messagingService.GetTopic("mytopic");
if(topic==null) //If topic not exists create it.
{
topic=messagingService.CreateTopic("mytopic");
}
Then publish message on topic.
object payload = "mymessage";
string sequenceName = "myOrderedMessages";
Message message = new Message(payload); //creating message
topic.Publish(message, DeliveryOption.All, sequenceName);