| Constructor and Description |
|---|
AbstractTopic(TopicKey key) |
| Modifier and Type | Method and Description |
|---|---|
void |
addTopicListener(TopicListener topicListener)
Adds listener through that topic events will be published (by calling
Topic.publishEvent(TopicEvent)). |
void |
checkSubscription(TopicKey topicKey,
Session session)
Checks that the given session can be subscribed to this topic
|
TopicKey |
getKey()
Returns the key which this topic is associated with
|
MessageDataSerializer |
getMessageDataSerializer()
Returns the
MessageDataSerializer that is associated with this topic |
boolean |
isAllowSubtopics()
Returns true if this topic allow to use subtopics
|
void |
publishEvent(TopicEvent event)
Publishes topic event to all subscribed TopicListeners
|
void |
removeTopicListener(TopicListener topicListener)
Removes topic listener
|
void |
setAllowSubtopics(boolean allowSubtopics)
Allow or disallow use of topics
|
void |
setMessageDataSerializer(MessageDataSerializer serializer)
Associated this topic with given
MessageDataSerializer |
public AbstractTopic(TopicKey key)
public MessageDataSerializer getMessageDataSerializer()
TopicMessageDataSerializer that is associated with this topicgetMessageDataSerializer in interface Topicpublic void setMessageDataSerializer(MessageDataSerializer serializer)
TopicMessageDataSerializersetMessageDataSerializer in interface Topicpublic boolean isAllowSubtopics()
public void setAllowSubtopics(boolean allowSubtopics)
public TopicKey getKey()
Topicpublic void addTopicListener(TopicListener topicListener)
TopicTopic.publishEvent(TopicEvent)).addTopicListener in interface Topicpublic void removeTopicListener(TopicListener topicListener)
TopicremoveTopicListener in interface Topicpublic void checkSubscription(TopicKey topicKey, Session session) throws SubscriptionFailureException
TopiccheckSubscription in interface TopicSubscriptionFailureException - when given session can't be subscribed to this topicpublic void publishEvent(TopicEvent event)
TopicpublishEvent in interface TopicCopyright © 2022 JBoss by Red Hat. All rights reserved.