Package 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	Description
static final String	IMPORT_FINISHED
static final String	IMPORT_STARTED

Constructor Summary

Constructors

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

Method Summary

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

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 Details

EventMessageConsumer

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

Method Details

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