com.atlassian.confluence.cluster.hazelcast

Class HazelcastTopicMessageRouter

java.lang.Object

com.atlassian.confluence.cluster.hazelcast.HazelcastTopicMessageRouter

public final class HazelcastTopicMessageRouter
extends Object

A component which manages subscriptions to multiple Hazelcast ITopics, routing messages on those topics to designed consumers for processing.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	HazelcastTopicMessageRouter.MessageConsumer<M>
static interface	HazelcastTopicMessageRouter.TopicFilter

Constructor Summary

Constructors

Constructor and Description
HazelcastTopicMessageRouter(Supplier<com.hazelcast.core.HazelcastInstance> hazelcastRef)

Method Summary

Modifier and Type	Method and Description
<M> void	registerMessageConsumer(HazelcastTopicMessageRouter.TopicFilter topicFilter, HazelcastTopicMessageRouter.MessageConsumer<M> messageConsumer) Registers a HazelcastTopicMessageRouter.MessageConsumer to receive all messages from topics that pass the HazelcastTopicMessageRouter.TopicFilter.
void	unregisterAllMessageConsumers()

Methods inherited from class java.lang.Object

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

Constructor Detail

HazelcastTopicMessageRouter

public HazelcastTopicMessageRouter(Supplier<com.hazelcast.core.HazelcastInstance> hazelcastRef)

Method Detail

registerMessageConsumer

public <M> void registerMessageConsumer(HazelcastTopicMessageRouter.TopicFilter topicFilter,
                                        HazelcastTopicMessageRouter.MessageConsumer<M> messageConsumer)

Registers a HazelcastTopicMessageRouter.MessageConsumer to receive all messages from topics that pass the HazelcastTopicMessageRouter.TopicFilter.

unregisterAllMessageConsumers

@PreDestroy
public void unregisterAllMessageConsumers()