com.atlassian.crowd.manager.cluster.message

Class ClusterMessageServiceImpl

java.lang.Object

com.atlassian.crowd.manager.cluster.message.ClusterMessageServiceImpl

All Implemented Interfaces:

ClusterMessageManager, ClusterMessageService, com.atlassian.scheduler.JobRunner

public class ClusterMessageServiceImpl
extends Object
implements ClusterMessageService, ClusterMessageManager, com.atlassian.scheduler.JobRunner

Constructor Summary

Constructors

Constructor and Description
ClusterMessageServiceImpl(com.atlassian.scheduler.SchedulerService schedulerService, ClusterMessageDao dao, ClusterService clusterService, com.atlassian.event.api.EventPublisher eventPublisher, Supplier<Long> timestampSupplier)

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	onApplicationStarted(com.atlassian.config.lifecycle.events.ApplicationStartedEvent e)
void	onXMLRestore(XMLRestoreFinishedEvent restoreFinishedEvent)
void	publish(String channel, String message) 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	registerSelf()
com.atlassian.scheduler.JobRunnerResponse	runJob(com.atlassian.scheduler.JobRunnerRequest request)
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.
void	unregisterSelf()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterMessageServiceImpl

public ClusterMessageServiceImpl(com.atlassian.scheduler.SchedulerService schedulerService,
                                 ClusterMessageDao dao,
                                 ClusterService clusterService,
                                 com.atlassian.event.api.EventPublisher eventPublisher,
                                 Supplier<Long> timestampSupplier)

Method Detail

registerSelf

@PostConstruct
public void registerSelf()

unregisterSelf

@PreDestroy
public void unregisterSelf()

onApplicationStarted

@EventListener
public void onApplicationStarted(com.atlassian.config.lifecycle.events.ApplicationStartedEvent e)

onXMLRestore

@EventListener
public void onXMLRestore(XMLRestoreFinishedEvent restoreFinishedEvent)

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

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 channel,
                    String message)

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:

channel - channel name, max. 64 characters.

message - message content, max. 1024 characters.

runJob

@Nullable
public com.atlassian.scheduler.JobRunnerResponse runJob(com.atlassian.scheduler.JobRunnerRequest request)

Specified by:

runJob in interface com.atlassian.scheduler.JobRunner

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.