Package org.nuxeo.ecm.restapi.server

Class ClusterActionPubSub

java.lang.Object

org.nuxeo.runtime.pubsub.AbstractPubSubBroker<ClusterAction>

org.nuxeo.ecm.restapi.server.ClusterActionPubSub

@Deprecated
public class ClusterActionPubSub
extends AbstractPubSubBroker<ClusterAction>

Deprecated.

since 2023.0, use ClusterActionService instead

PubSub to propagate an action to all nodes in the cluster.

Since:

2021.25

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLUSTER_ACTION_PUB_SUB_TOPIC	Deprecated.
static final String	START_CONSUMER_ACTION	Deprecated.
static final String	STOP_CONSUMER_ACTION	Deprecated.

Fields inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker

DISCRIMINATOR_SEP, discriminatorBytes, topic

Constructor Summary

Constructors

Constructor	Description
ClusterActionPubSub()	Deprecated.

Method Summary

Modifier and Type	Method	Description
ClusterAction	deserialize(InputStream in)	Deprecated. Deserializes an InputStream into a message, or null.
void	receivedMessage(ClusterAction message)	Deprecated. Callback implementing the delivery of a message from another node.
void	sendClusterAction(String action, String param)	Deprecated.

Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker

close, initialize, scanDiscriminator, sendMessage, subscriber

Methods inherited from class java.lang.Object

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

Field Details

CLUSTER_ACTION_PUB_SUB_TOPIC

public static final String CLUSTER_ACTION_PUB_SUB_TOPIC

Deprecated.

See Also:

• Constant Field Values

START_CONSUMER_ACTION

public static final String START_CONSUMER_ACTION

Deprecated.

See Also:

• Constant Field Values

STOP_CONSUMER_ACTION

public static final String STOP_CONSUMER_ACTION

Deprecated.

See Also:

• Constant Field Values

Constructor Details

ClusterActionPubSub

public ClusterActionPubSub()

Deprecated.

Method Details

deserialize

public ClusterAction deserialize(InputStream in)
                          throws IOException

Deprecated.

Description copied from class: AbstractPubSubBroker

Deserializes an InputStream into a message, or null.

Specified by:

deserialize in class AbstractPubSubBroker<ClusterAction>

Throws:

IOException

sendClusterAction

public void sendClusterAction(String action,
 String param)

Deprecated.

receivedMessage

public void receivedMessage(ClusterAction message)

Deprecated.

Description copied from class: AbstractPubSubBroker

Callback implementing the delivery of a message from another node.

Specified by:

receivedMessage in class AbstractPubSubBroker<ClusterAction>

Parameters:

message - the received message