org.jboss.messaging.core.remoting.impl.wireformat
Class SessionCreateConsumerMessage

java.lang.Object
  extended by org.jboss.messaging.core.remoting.impl.wireformat.EmptyPacket
      extended by org.jboss.messaging.core.remoting.impl.wireformat.SessionCreateConsumerMessage
All Implemented Interfaces:
Packet

public class SessionCreateConsumerMessage
extends EmptyPacket

Version:
$Revision$
Author:
Tim Fox

Field Summary
 
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
 
Constructor Summary
SessionCreateConsumerMessage()
           
SessionCreateConsumerMessage(long clientTargetID, SimpleString queueName, SimpleString filterString, boolean noLocal, boolean autoDeleteQueue, int windowSize, int maxRate)
           
 
Method Summary
 void decodeBody(MessagingBuffer buffer)
           
 void encodeBody(MessagingBuffer buffer)
           
 long getClientTargetID()
           
 SimpleString getFilterString()
           
 int getMaxRate()
           
 SimpleString getQueueName()
           
 int getWindowSize()
           
 boolean isAutoDeleteQueue()
           
 boolean isNoLocal()
           
 java.lang.String toString()
           
 
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
 

Constructor Detail

SessionCreateConsumerMessage

public SessionCreateConsumerMessage(long clientTargetID,
                                    SimpleString queueName,
                                    SimpleString filterString,
                                    boolean noLocal,
                                    boolean autoDeleteQueue,
                                    int windowSize,
                                    int maxRate)

SessionCreateConsumerMessage

public SessionCreateConsumerMessage()
Method Detail

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.