org.hornetq.core.protocol.core.impl.wireformat

Class CreateSessionMessage

java.lang.Object

org.hornetq.core.protocol.core.impl.PacketImpl

org.hornetq.core.protocol.core.impl.wireformat.CreateSessionMessage

All Implemented Interfaces:

Packet

public class CreateSessionMessage
extends PacketImpl

Version:

$Revision$

Author:

Tim Fox, Jeff Mesnil.

Field Summary

Fields inherited from class org.hornetq.core.protocol.core.impl.PacketImpl

channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_QUEUE, CREATE_REPLICATION, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, REATTACH_SESSION, REATTACH_SESSION_RESP, REPLICATION_APPEND, REPLICATION_APPEND_TX, REPLICATION_COMMIT_ROLLBACK, REPLICATION_COMPARE_DATA, REPLICATION_DELETE, REPLICATION_DELETE_TX, REPLICATION_LARGE_MESSAGE_BEGIN, REPLICATION_LARGE_MESSAGE_END, REPLICATION_LARGE_MESSAGE_WRITE, REPLICATION_PAGE_EVENT, REPLICATION_PAGE_WRITE, REPLICATION_PREPARE, REPLICATION_RESPONSE, REPLICATION_SYNC, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_CLOSE, SESS_COMMIT, SESS_CONSUMER_CLOSE, SESS_CREATECONSUMER, SESS_EXPIRED, SESS_FLOWTOKEN, SESS_FORCE_CONSUMER_DELIVERY, SESS_INDIVIDUAL_ACKNOWLEDGE, SESS_PRODUCER_CREDITS, SESS_PRODUCER_REQUEST_CREDITS, SESS_QUEUEQUERY, SESS_QUEUEQUERY_RESP, SESS_RECEIVE_CONTINUATION, SESS_RECEIVE_LARGE_MSG, SESS_RECEIVE_MSG, SESS_ROLLBACK, SESS_SEND, SESS_SEND_CONTINUATION, SESS_SEND_LARGE, SESS_START, SESS_STOP, SESS_UNIQUE_ADD_METADATA, SESS_XA_COMMIT, SESS_XA_END, SESS_XA_FORGET, SESS_XA_GET_TIMEOUT, SESS_XA_GET_TIMEOUT_RESP, SESS_XA_INDOUBT_XIDS, SESS_XA_INDOUBT_XIDS_RESP, SESS_XA_JOIN, SESS_XA_PREPARE, SESS_XA_RESP, SESS_XA_RESUME, SESS_XA_ROLLBACK, SESS_XA_SET_TIMEOUT, SESS_XA_SET_TIMEOUT_RESP, SESS_XA_START, SESS_XA_SUSPEND, size, SUBSCRIBE_TOPOLOGY, SUBSCRIBE_TOPOLOGY_V2, type

Constructor Summary

Constructors

Constructor and Description
CreateSessionMessage()
CreateSessionMessage(String name, long sessionChannelID, int version, String username, String password, int minLargeMessageSize, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int windowSize, String defaultAddress)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
boolean	equals(Object other)
String	getDefaultAddress()
int	getMinLargeMessageSize()
String	getName()
String	getPassword()
long	getSessionChannelID()
String	getUsername()
int	getVersion()
int	getWindowSize()
boolean	isAutoCommitAcks()
boolean	isAutoCommitSends()
boolean	isPreAcknowledge()
boolean	isRequiresConfirmations() returns true if a confirmation should be sent on receipt of this packet.
boolean	isXA()

Methods inherited from class org.hornetq.core.protocol.core.impl.PacketImpl

decode, encode, getChannelID, getPacketSize, getParentString, getType, isAsyncExec, isResponse, nullableStringEncodeSize, setChannelID, stringEncodeSize, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateSessionMessage

public CreateSessionMessage(String name,
                    long sessionChannelID,
                    int version,
                    String username,
                    String password,
                    int minLargeMessageSize,
                    boolean xa,
                    boolean autoCommitSends,
                    boolean autoCommitAcks,
                    boolean preAcknowledge,
                    int windowSize,
                    String defaultAddress)

CreateSessionMessage

public CreateSessionMessage()

Method Detail

getName

public String getName()

getSessionChannelID

public long getSessionChannelID()

getVersion

public int getVersion()

getUsername

public String getUsername()

getPassword

public String getPassword()

isXA

public boolean isXA()

isAutoCommitSends

public boolean isAutoCommitSends()

isAutoCommitAcks

public boolean isAutoCommitAcks()

isPreAcknowledge

public boolean isPreAcknowledge()

getWindowSize

public int getWindowSize()

getDefaultAddress

public String getDefaultAddress()

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class PacketImpl

equals

public boolean equals(Object other)

Overrides:

equals in class PacketImpl

isRequiresConfirmations

public final boolean isRequiresConfirmations()

Description copied from interface: Packet

returns true if a confirmation should be sent on receipt of this packet.

Specified by:

isRequiresConfirmations in interface Packet

Overrides:

isRequiresConfirmations in class PacketImpl

Returns:

true if confirmation is required

getMinLargeMessageSize

public int getMinLargeMessageSize()