public class

DatabaseClusterMessagingService

extends Object
implements ClusterMessagingService
java.lang.Object
   ↳ com.atlassian.jira.cluster.DatabaseClusterMessagingService

Class Overview

Provides an implementation for the ClusterMessagingService that wraps an existing MessageHandlerService in order to provide an API that can be consumed by plugins.

Summary

Public Constructors
DatabaseClusterMessagingService(MessageHandlerService messageHandlerService)
Public Methods
void registerListener(String channel, ClusterMessageConsumer consumer)
Register a ClusterMessageConsumer to receive messages sent to the nominated channel.
void sendRemote(String channel, String message)
Sends an inter-node message to registered listeners, listeners on the node the message was raised will not be notified.
void unregisterListener(ClusterMessageConsumer consumer)
Removes a ClusterMessageConsumer from all channels.
void unregisterListener(String channel, ClusterMessageConsumer consumer)
Removes a ClusterMessageConsumer from the channel.
[Expand]
Inherited Methods
From class java.lang.Object
From interface com.atlassian.jira.cluster.ClusterMessagingService

Public Constructors

public DatabaseClusterMessagingService (MessageHandlerService messageHandlerService)

Public Methods

public void registerListener (String channel, ClusterMessageConsumer consumer)

Register a ClusterMessageConsumer to receive messages sent to the nominated channel.

The receive method of the ClusterMessageConsumer will be invoked when a message is sent to a channel it is listening to. Registering a new listener for a channel will not remove any existing listeners on that channel. Listeners are weakly referenced, it is the responsibility of the caller to ensure that listeners are not prematurely garbage collected.

Parameters
channel The name of the channel
consumer The consumer that will receive messages

public void sendRemote (String channel, String message)

Sends an inter-node message to registered listeners, listeners on the node the message was raised will not be notified.

Parameters
channel The name of the channel (up to 20 alphanumeric characters in length)
message The message to send (up to 200 characters in length)

public void unregisterListener (ClusterMessageConsumer consumer)

Removes a ClusterMessageConsumer from all channels.

The ClusterMessageConsumer will no longer receive any messages.

Parameters
consumer The consumer to be unregistered

public void unregisterListener (String channel, ClusterMessageConsumer consumer)

Removes a ClusterMessageConsumer from the channel.

The ClusterMessageConsumer will no longer receive messages that are sent to the nominated channel.

Parameters
channel The name of the channel
consumer The consumer to be unregistered