Package org.nuxeo.runtime.pubsub
Class ClusterActionServiceImpl.ClusterActionPubSub
java.lang.Object
org.nuxeo.runtime.pubsub.AbstractPubSubBroker<ClusterActionMessage>
org.nuxeo.runtime.pubsub.ClusterActionServiceImpl.ClusterActionPubSub
- Enclosing class:
- ClusterActionServiceImpl
public class ClusterActionServiceImpl.ClusterActionPubSub
extends AbstractPubSubBroker<ClusterActionMessage>
PubSub to propagate an action to all nodes in the cluster.
- Since:
- 2023.0
-
Field Summary
Fields inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker
DISCRIMINATOR_SEP, discriminatorBytes, topic
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionDeserializes anInputStream
into a message, ornull
.void
receivedMessage
(ClusterActionMessage message) Callback implementing the delivery of a message from another node.void
sendMessage
(ClusterActionMessage message) Sends a message to other nodes.Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker
close, initialize, scanDiscriminator, subscriber
-
Field Details
-
CLUSTER_ACTION_PUB_SUB_TOPIC
- See Also:
-
-
Constructor Details
-
ClusterActionPubSub
public ClusterActionPubSub()
-
-
Method Details
-
deserialize
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<ClusterActionMessage>
- Throws:
IOException
-
sendMessage
Description copied from class:AbstractPubSubBroker
Sends a message to other nodes.- Overrides:
sendMessage
in classAbstractPubSubBroker<ClusterActionMessage>
-
receivedMessage
Description copied from class:AbstractPubSubBroker
Callback implementing the delivery of a message from another node.- Specified by:
receivedMessage
in classAbstractPubSubBroker<ClusterActionMessage>
- Parameters:
message
- the received message
-