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

Fields

Modifier and Type	Field and Description
static String	IMPORT_FINISHED
static String	IMPORT_STARTED

Constructor Summary

Constructors

Constructor and Description
EventMessageConsumer(com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
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