public class

EventMessageConsumer

extends Object
implements ClusterMessageConsumer
java.lang.Object
   ↳ com.atlassian.jira.cluster.EventMessageConsumer

Class Overview

Consumes cluster messages and pushes them out to the EventPublisher.

Summary

Constants
String IMPORT_FINISHED
String IMPORT_STARTED
Public Constructors
EventMessageConsumer(EventPublisher eventPublisher)
Public Methods
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.
[Expand]
Inherited Methods
From class java.lang.Object
From interface com.atlassian.jira.cluster.ClusterMessageConsumer

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 importFinishedMessage (Boolean success)

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