org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Class CreateSessionMessage

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateSessionMessage

All Implemented Interfaces:

Packet

public class CreateSessionMessage
extends PacketImpl

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, BACKUP_REQUEST, BACKUP_REQUEST_RESPONSE, channelID, CHECK_FOR_FAILOVER, CHECK_FOR_FAILOVER_REPLY, CLUSTER_CONNECT, CLUSTER_CONNECT_REPLY, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CLUSTER_TOPOLOGY_V3, CREATE_QUEUE, CREATE_SHARED_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_V2, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, QUORUM_VOTE, QUORUM_VOTE_REPLY, REATTACH_SESSION, REATTACH_SESSION_RESP, REPLICATION_APPEND, REPLICATION_APPEND_TX, REPLICATION_COMMIT_ROLLBACK, 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_RESPONSE_V2, REPLICATION_SCHEDULED_FAILOVER, REPLICATION_START_FINISH_SYNC, REPLICATION_SYNC_FILE, SCALEDOWN_ANNOUNCEMENT, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_BINDINGQUERY_RESP_V2, 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_FAIL_CREDITS, SESS_PRODUCER_REQUEST_CREDITS, SESS_QUEUEQUERY, SESS_QUEUEQUERY_RESP, SESS_QUEUEQUERY_RESP_V2, 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_FAILED, 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

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

Modifier and Type	Method and Description
void	decodeRest(ActiveMQBuffer buffer)
void	encodeRest(ActiveMQBuffer buffer)
boolean	equals(Object obj)
String	getDefaultAddress()
int	getMinLargeMessageSize()
String	getName()
String	getPassword()
long	getSessionChannelID()
String	getUsername()
int	getVersion()
int	getWindowSize()
int	hashCode()
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.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, 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(ActiveMQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(ActiveMQBuffer buffer)

Overrides:

decodeRest 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()

hashCode

public int hashCode()

Overrides:

hashCode in class PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl