Provides functionality for topic-based message exchange among nodes defined by IClusterGroup. Users can send ordered and unordered messages to various topics. Note that same topic name cannot be reused between ordered and unordered messages. All members are thread-safe and may be used concurrently from multiple threads. More...

Public Member Functions
void	Send (object message, object topic=null)
	Sends a message with specified topic to the nodes in the underlying cluster group. More...

void	SendAll (IEnumerable messages, object topic=null)
	Sends messages with specified topic to the nodes in the underlying cluster group. More...

void	SendOrdered (object message, object topic=null, TimeSpan?timeout=null)
	Sends a message with specified topic to the nodes in the underlying cluster group. Messages sent with this method will arrive in the same order they were sent. Note that if a topic is used for ordered messages, then it cannot be reused for non-ordered messages. More...

void	LocalListen< T > (IMessageListener< T > listener, object topic=null)
	Adds local listener for given topic on local node only. This listener will be notified whenever any node within the cluster group will send a message for a given topic to this node. Local listen subscription will happen regardless of whether local node belongs to this cluster group or not. More...

void	StopLocalListen< T > (IMessageListener< T > listener, object topic=null)
	Unregisters local listener for given topic on local node only. More...

Guid	RemoteListen< T > (IMessageListener< T > listener, object topic=null)
	Adds a message listener for a given topic to all nodes in the cluster group (possibly including this node if it belongs to the cluster group as well). This means that any node within this cluster group can send a message for a given topic and all nodes within the cluster group will receive listener notifications. More...

Task< Guid >	RemoteListenAsync< T > (IMessageListener< T > listener, object topic=null)
	Adds a message listener for a given topic to all nodes in the cluster group (possibly including this node if it belongs to the cluster group as well). This means that any node within this cluster group can send a message for a given topic and all nodes within the cluster group will receive listener notifications. More...

void	StopRemoteListen (Guid opId)
	Unregisters all listeners identified with provided operation ID on all nodes in the cluster group. More...

Task	StopRemoteListenAsync (Guid opId)
	Unregisters all listeners identified with provided operation ID on all nodes in the cluster group. More...

Properties
IClusterGroup	ClusterGroup `[get]`
	Gets the cluster group to which this instance belongs. More...

Detailed Description

Member Function Documentation

void Apache.Ignite.Core.Messaging.IMessaging.LocalListen< T >	(	IMessageListener< T >	listener,
		object	topic = `null`
	)

Parameters

listener	Predicate that is called on each received message. If predicate returns false, then it will be unsubscribed from any further notifications.
topic	Topic to subscribe to.

Guid Apache.Ignite.Core.Messaging.IMessaging.RemoteListen< T >	(	IMessageListener< T >	listener,
		object	topic = `null`
	)

Parameters

listener	Predicate that is called on each received message. If predicate returns false, then it will be unsubscribed from any further notifications.
topic	Topic to unsubscribe from.

Returns: Operation ID that can be passed to StopRemoteListen method to stop listening.

Task<Guid> Apache.Ignite.Core.Messaging.IMessaging.RemoteListenAsync< T >	(	IMessageListener< T >	listener,
		object	topic = `null`
	)

Parameters

listener	Predicate that is called on each received message. If predicate returns false, then it will be unsubscribed from any further notifications.
topic	Topic to unsubscribe from.

Returns: Operation ID that can be passed to StopRemoteListen method to stop listening.

void Apache.Ignite.Core.Messaging.IMessaging.Send	(	object	message,
		object	topic = `null`
	)

Parameters

message	Message to send.
topic	Topic to send to, null for default topic.

void Apache.Ignite.Core.Messaging.IMessaging.SendAll	(	IEnumerable	messages,
		object	topic = `null`
	)

Parameters

messages	Messages to send.
topic	Topic to send to, null for default topic.

void Apache.Ignite.Core.Messaging.IMessaging.SendOrdered	(	object	message,
		object	topic = `null`,
		TimeSpan?	timeout = `null`
	)

Parameters

message	Message to send.
topic	Topic to send to, null for default topic.
timeout	Message timeout, null for for default value from configuration (IgniteConfiguration.getNetworkTimeout).

void Apache.Ignite.Core.Messaging.IMessaging.StopLocalListen< T >	(	IMessageListener< T >	listener,
		object	topic = `null`
	)

Parameters

listener	Listener predicate.
topic	Topic to unsubscribe from.

void Apache.Ignite.Core.Messaging.IMessaging.StopRemoteListen ( Guid opId )

Parameters

opId	Operation ID that was returned from RemoteListen<T> method.

Task Apache.Ignite.Core.Messaging.IMessaging.StopRemoteListenAsync ( Guid opId )

Parameters

opId	Operation ID that was returned from RemoteListen<T> method.

Property Documentation

IClusterGroup Apache.Ignite.Core.Messaging.IMessaging.ClusterGroup

get

Public Member Functions

Properties

Detailed Description

Member Function Documentation

Property Documentation