com.atlassian.jira.cluster
Class EventMessageConsumer

java.lang.Object
  com.atlassian.jira.cluster.EventMessageConsumer

All Implemented Interfaces:

ClusterMessageConsumer

public class EventMessageConsumer
extends Object
implements ClusterMessageConsumer

Consumes cluster messages and pushes them out to the EventPublisher.

Since:

v6.3

Field Summary

static String	IMPORT_FINISHED
static String	IMPORT_STARTED

Constructor Summary

EventMessageConsumer(com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

static Message	importFinishedMessage(Boolean success)
static Message	importStartedMessage()
void	receive(String channel, String message, String senderId) Called by the ClusterMessagingService when there is a message waiting to be processed by a node.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

IMPORT_STARTED

public static final String IMPORT_STARTED

See Also:

Constant Field Values

IMPORT_FINISHED

public static final String IMPORT_FINISHED

See Also:

Constant Field Values

Constructor Detail

EventMessageConsumer

public EventMessageConsumer(com.atlassian.event.api.EventPublisher eventPublisher)

Method Detail

importFinishedMessage

public static Message importFinishedMessage(Boolean success)

importStartedMessage

public static Message importStartedMessage()

receive

public void receive(String channel,
                    String message,
                    String senderId)

Description copied from interface: ClusterMessageConsumer

Called by the ClusterMessagingService when there is a message waiting to be processed by a node.

Specified by:

receive in interface ClusterMessageConsumer

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