Class Overview
Consumes cluster messages and pushes them out to the EventPublisher.
Constants
public
static
final
String
IMPORT_FINISHED
Constant Value:
"Import Done"
public
static
final
String
IMPORT_STARTED
Constant Value:
"Import Started"
Public Constructors
public
EventMessageConsumer
(EventPublisher eventPublisher)
Public Methods
public
static
Message
importStartedMessage
()
public
void
receive
(String channel, String message, String senderId)
Called by the ClusterMessagingService when there is a message waiting to be processed by a node.
Parameters
channel
| The channel the message was sent to |
message
| The content of the message |
senderId
| The id of the node that raised the message
|