Package com.atlassian.bamboo.cluster.clustermessage

Class ClusterMessageXStreamPublisher

java.lang.Object

com.atlassian.bamboo.cluster.clustermessage.ClusterMessageXStreamPublisher

All Implemented Interfaces:

ClusterMessagePublisher

public class ClusterMessageXStreamPublisher
extends Object
implements ClusterMessagePublisher

Constructor Summary

Constructors

Constructor	Description
ClusterMessageXStreamPublisher(@NotNull CrossNodesRemoteBroadcaster crossNodesRemoteBroadcaster, @NotNull XStreamManager xStreamManager)

Method Summary

Modifier and Type	Method	Description
<T extends ClusterMessage> void	publish(T message)	Publishes a message to the cluster.

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterMessageXStreamPublisher

@Inject
public ClusterMessageXStreamPublisher(@NotNull
 @NotNull CrossNodesRemoteBroadcaster crossNodesRemoteBroadcaster,
 @NotNull
 @NotNull XStreamManager xStreamManager)

Method Details

publish

public <T extends ClusterMessage> void publish(@NotNull
 T message)

Description copied from interface: ClusterMessagePublisher

Publishes a message to the cluster. Implementations of this method are responsible for serializing the message and sending it to other nodes.

Specified by:

publish in interface ClusterMessagePublisher

Type Parameters:

T - the type of the message, which must extend ClusterMessage

Parameters:

message - the message to be published, must not be null