org.axonframework.jgroups.commandhandling

Class JGroupsDispatchMessage

java.lang.Object

org.axonframework.commandhandling.distributed.DispatchMessage

org.axonframework.jgroups.commandhandling.JGroupsDispatchMessage

All Implemented Interfaces:

Externalizable, Serializable, org.jgroups.util.Streamable

public class JGroupsDispatchMessage
extends DispatchMessage
implements org.jgroups.util.Streamable, Externalizable

JGroups message that contains a CommandMessage that needs to be dispatched on a remote command bus segment. This class implements the Streamable interface for faster JGroups-specific serialization, but also supports Java serialization by implementing the Externalizable interface.

Since:

2.0

Author:

Allard Buijze

See Also:

Serialized Form

Field Summary

Fields inherited from class org.axonframework.commandhandling.distributed.DispatchMessage

commandIdentifier, commandName, expectReply, payloadRevision, payloadType, serializedMetaData, serializedPayload

Constructor Summary

Constructors

Constructor and Description
JGroupsDispatchMessage() Default constructor required by the Streamable and Externalizable interfaces.
JGroupsDispatchMessage(CommandMessage<?> commandMessage, Serializer serializer, boolean expectReply) Initialize a JGroupsDispatchMessage for the given commandMessage, to be serialized using given serializer.

Method Summary

Modifier and Type	Method and Description
void	readExternal(ObjectInput in)
void	readFrom(DataInput in)
void	writeExternal(ObjectOutput out)
void	writeTo(DataOutput out)

Methods inherited from class org.axonframework.commandhandling.distributed.DispatchMessage

equals, getCommandIdentifier, getCommandMessage, getCommandName, getPayloadRevision, getPayloadType, getSerializedMetaData, getSerializedPayload, hashCode, isExpectReply, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

JGroupsDispatchMessage

public JGroupsDispatchMessage()

Default constructor required by the Streamable and Externalizable interfaces. Do not use directly.

JGroupsDispatchMessage

public JGroupsDispatchMessage(CommandMessage<?> commandMessage,
                              Serializer serializer,
                              boolean expectReply)

Initialize a JGroupsDispatchMessage for the given commandMessage, to be serialized using given serializer. expectReply indicates whether the sender will be expecting a reply.

Parameters:

commandMessage - The message to send to the remote segment

serializer - The serialize to serialize the message payload and metadata with

expectReply - whether or not the sender is waiting for a reply.

Method Detail

writeTo

public void writeTo(DataOutput out)
             throws IOException

Specified by:

writeTo in interface org.jgroups.util.Streamable

Throws:

IOException

readFrom

public void readFrom(DataInput in)
              throws IOException

Specified by:

readFrom in interface org.jgroups.util.Streamable

Throws:

IOException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException

Specified by:

readExternal in interface Externalizable

Throws:

IOException