@Deprecated public final class HazelcastTopicMessageRouter extends Object
ITopic
s, routing messages on those topics to
designed consumers for processing.Modifier and Type | Class and Description |
---|---|
static interface |
HazelcastTopicMessageRouter.MessageConsumer<M>
Deprecated.
|
static interface |
HazelcastTopicMessageRouter.TopicFilter
Deprecated.
|
Constructor and Description |
---|
HazelcastTopicMessageRouter(com.hazelcast.core.HazelcastInstance hazelcastInstance)
Deprecated.
|
HazelcastTopicMessageRouter(Supplier<com.hazelcast.core.HazelcastInstance> hazelcastRef)
Deprecated.
since 7.6
|
Modifier and Type | Method and Description |
---|---|
<M> void |
registerMessageConsumer(HazelcastTopicMessageRouter.TopicFilter topicFilter,
HazelcastTopicMessageRouter.MessageConsumer<M> messageConsumer)
Deprecated.
Registers a
HazelcastTopicMessageRouter.MessageConsumer to receive all messages from topics that pass the HazelcastTopicMessageRouter.TopicFilter . |
void |
unregisterAllMessageConsumers()
Deprecated.
|
public HazelcastTopicMessageRouter(com.hazelcast.core.HazelcastInstance hazelcastInstance)
@Deprecated public HazelcastTopicMessageRouter(Supplier<com.hazelcast.core.HazelcastInstance> hazelcastRef)
public <M> void registerMessageConsumer(HazelcastTopicMessageRouter.TopicFilter topicFilter, HazelcastTopicMessageRouter.MessageConsumer<M> messageConsumer)
HazelcastTopicMessageRouter.MessageConsumer
to receive all messages from topics that pass the HazelcastTopicMessageRouter.TopicFilter
.@PreDestroy public void unregisterAllMessageConsumers()
Copyright © 2003–2023 Atlassian. All rights reserved.
View cookie preferences