com.atlassian.confluence.cluster.hazelcast

Class HazelcastExecutorClusterEventService

java.lang.Object

com.atlassian.confluence.cluster.hazelcast.HazelcastExecutorClusterEventService

All Implemented Interfaces:

HazelcastClusterEventService

public class HazelcastExecutorClusterEventService
extends Object
implements HazelcastClusterEventService

An implementation of HazelcastClusterEventService which uses a Hazelcast remote executor to distribute events. This is probably not the most efficient way to do this - using a Hazelcast ITopic is likely to perform better.

Since:

5.5

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	EXECUTOR_SVC_NAME Name of the executor service to use for executing tasks.

Constructor Summary

Constructors

Constructor and Description
HazelcastExecutorClusterEventService(com.hazelcast.core.HazelcastInstance hazelcast)

Method Summary

Modifier and Type	Method and Description
com.hazelcast.core.IExecutorService	getExecutorService() Returns the distributed executor service for the given
void	publishEventToCluster(Object clusterEvent)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

EXECUTOR_SVC_NAME

protected static final String EXECUTOR_SVC_NAME

Name of the executor service to use for executing tasks.

See Also:

Constant Field Values

Constructor Detail

HazelcastExecutorClusterEventService

public HazelcastExecutorClusterEventService(com.hazelcast.core.HazelcastInstance hazelcast)

Method Detail

publishEventToCluster

public void publishEventToCluster(Object clusterEvent)

Specified by:

publishEventToCluster in interface HazelcastClusterEventService

start

public void start()

Specified by:

start in interface HazelcastClusterEventService

stop

public void stop()

Specified by:

stop in interface HazelcastClusterEventService

getExecutorService

public com.hazelcast.core.IExecutorService getExecutorService()

Description copied from interface: HazelcastClusterEventService

Returns the distributed executor service for the given

Note: Note that it don't support invokeAll/Any and don't have standard shutdown behavior

See HazelcastInstance.getExecutorService(String) for more details

Specified by:

getExecutorService in interface HazelcastClusterEventService

Returns:

executor service