com.atlassian.jira.cluster
Class OfBizMessageHandlerService

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

All Implemented Interfaces:

MessageHandler

public class OfBizMessageHandlerService
extends Object
implements MessageHandler

Polls the database on a regular interval to see if there are actions to perform

Since:

v6.1

Constructor Summary

OfBizMessageHandlerService(NodeStateManager nodeStateManager, OfBizClusterMessageStore clusterMessageStore, com.atlassian.event.api.EventPublisher eventPublisher, ListenerManager listenerManager)

Method Summary

List<ClusterMessage>	receiveMessages()
ClusterMessage	sendMessage(String destinationId, Message message)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

OfBizMessageHandlerService

public OfBizMessageHandlerService(NodeStateManager nodeStateManager,
                                  OfBizClusterMessageStore clusterMessageStore,
                                  com.atlassian.event.api.EventPublisher eventPublisher,
                                  ListenerManager listenerManager)

Method Detail

sendMessage

@Nullable
public ClusterMessage sendMessage(String destinationId,
                                           Message message)

Specified by:

sendMessage in interface MessageHandler

receiveMessages

public List<ClusterMessage> receiveMessages()

Specified by:

receiveMessages in interface MessageHandler

start

public void start()

Specified by:

start in interface MessageHandler

stop

public void stop()

Specified by:

stop in interface MessageHandler