com.atlassian.crowd.manager.cluster.message

Class NoOpClusterMessageService

java.lang.Object

com.atlassian.crowd.manager.cluster.message.NoOpClusterMessageService

All Implemented Interfaces:

ClusterMessageManager, ClusterMessageService

public class NoOpClusterMessageService
extends Object
implements ClusterMessageService, ClusterMessageManager

Dummy implementation used when running in non-clustered mode.

Constructor Summary

Constructors

Constructor and Description
NoOpClusterMessageService()

Method Summary

Modifier and Type	Method and Description
void	deleteMessagesOlderThan(Instant instant) Removes all stored messages older than the specified instant
void	deleteOldMessages() Delete messages with timestamp older than an implementation-defined threshold.
List<InternalClusterMessage>	getAllMessages()
void	publish(String message, String channel) Send a message to other nodes (excluding the sender), notifying all listeners on a specific channel.
void	registerListener(ClusterMessageListener listener, String channel) Register a listener on a channel.
void	start() Start polling for new messages.
void	stop() Stop polling for new messages and ignore any late messages on start().
void	unregisterListener(ClusterMessageListener listener) Unregister a listener from all channels.
void	unregisterListener(ClusterMessageListener listener, String channel) Unregister a listener from a specific channel.

Methods inherited from class java.lang.Object

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

Constructor Detail

NoOpClusterMessageService

public NoOpClusterMessageService()

Method Detail

start

public void start()

Description copied from interface: ClusterMessageManager

Start polling for new messages.

Specified by:

start in interface ClusterMessageManager

stop

public void stop()

Description copied from interface: ClusterMessageManager

Stop polling for new messages and ignore any late messages on start().

Specified by:

stop in interface ClusterMessageManager

getAllMessages

public List<InternalClusterMessage> getAllMessages()

Specified by:

getAllMessages in interface ClusterMessageManager

Returns:

all stored messages, including entries already processed or sent by the calling node.

deleteOldMessages

public void deleteOldMessages()

Description copied from interface: ClusterMessageManager

Delete messages with timestamp older than an implementation-defined threshold.

Specified by:

deleteOldMessages in interface ClusterMessageManager

deleteMessagesOlderThan

public void deleteMessagesOlderThan(Instant instant)

Description copied from interface: ClusterMessageManager

Removes all stored messages older than the specified instant

Specified by:

deleteMessagesOlderThan in interface ClusterMessageManager

registerListener

public void registerListener(ClusterMessageListener listener,
                             String channel)

Description copied from interface: ClusterMessageService

Register a listener on a channel.

Specified by:

registerListener in interface ClusterMessageService

unregisterListener

public void unregisterListener(ClusterMessageListener listener,
                               String channel)

Description copied from interface: ClusterMessageService

Unregister a listener from a specific channel.

Specified by:

unregisterListener in interface ClusterMessageService

unregisterListener

public void unregisterListener(ClusterMessageListener listener)

Description copied from interface: ClusterMessageService

Unregister a listener from all channels.

Specified by:

unregisterListener in interface ClusterMessageService

publish

public void publish(String message,
                    String channel)

Description copied from interface: ClusterMessageService

Send a message to other nodes (excluding the sender), notifying all listeners on a specific channel.

Specified by:

publish in interface ClusterMessageService

Parameters:

message - channel name, max. 64 characters.

channel - message content, max. 1024 characters.