org.jboss.messaging.core.remoting.impl.wireformat
Class SessionCreateConsumerMessage
java.lang.Object
org.jboss.messaging.core.remoting.impl.wireformat.EmptyPacket
org.jboss.messaging.core.remoting.impl.wireformat.SessionCreateConsumerMessage
- All Implemented Interfaces:
- Packet
public class SessionCreateConsumerMessage
- extends EmptyPacket
- Version:
- $Revision$
- Author:
- Tim Fox
Fields inherited from class org.jboss.messaging.core.remoting.impl.wireformat.EmptyPacket |
CLOSE, CONN_CREATESESSION, CONN_CREATESESSION_RESP, CONN_START, CONN_STOP, CONS_FLOWTOKEN, CREATECONNECTION, CREATECONNECTION_RESP, EXCEPTION, NULL, PING, PONG, PROD_RECEIVETOKENS, PROD_SEND, RECEIVE_MSG, SESS_ACKNOWLEDGE, SESS_ADD_DESTINATION, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_BROWSER_HASNEXTMESSAGE, SESS_BROWSER_HASNEXTMESSAGE_RESP, SESS_BROWSER_NEXTMESSAGE, SESS_BROWSER_RESET, SESS_CANCEL, SESS_COMMIT, SESS_CREATEBROWSER, SESS_CREATEBROWSER_RESP, SESS_CREATECONSUMER, SESS_CREATECONSUMER_RESP, SESS_CREATEPRODUCER, SESS_CREATEPRODUCER_RESP, SESS_CREATEQUEUE, SESS_DELETE_QUEUE, SESS_QUEUEQUERY, SESS_QUEUEQUERY_RESP, SESS_RECOVER, SESS_REMOVE_DESTINATION, SESS_ROLLBACK, 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 |
Fields inherited from interface org.jboss.messaging.core.remoting.Packet |
NO_ID_SET |
Methods inherited from class org.jboss.messaging.core.remoting.impl.wireformat.EmptyPacket |
decode, encode, getExecutorID, getParentString, getResponseTargetID, getTargetID, getType, normalize, setExecutorID, setResponseTargetID, setTargetID |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
SessionCreateConsumerMessage
public SessionCreateConsumerMessage(long clientTargetID,
SimpleString queueName,
SimpleString filterString,
boolean noLocal,
boolean autoDeleteQueue,
int windowSize,
int maxRate)
SessionCreateConsumerMessage
public SessionCreateConsumerMessage()
toString
public java.lang.String toString()
- Overrides:
toString
in class EmptyPacket
getClientTargetID
public long getClientTargetID()
getQueueName
public SimpleString getQueueName()
getFilterString
public SimpleString getFilterString()
isNoLocal
public boolean isNoLocal()
isAutoDeleteQueue
public boolean isAutoDeleteQueue()
getWindowSize
public int getWindowSize()
getMaxRate
public int getMaxRate()
encodeBody
public void encodeBody(MessagingBuffer buffer)
- Overrides:
encodeBody
in class EmptyPacket
decodeBody
public void decodeBody(MessagingBuffer buffer)
- Overrides:
decodeBody
in class EmptyPacket
Copyright © 2006 JBoss Inc. All Rights Reserved.