Class AbstractJmsMessage
- java.lang.Object
-
- org.objectweb.joram.shared.client.AbstractJmsMessage
-
- All Implemented Interfaces:
Encodable,Streamable,Externalizable,Serializable
- Direct Known Subclasses:
AbstractJmsReply,AbstractJmsRequest
public abstract class AbstractJmsMessage extends Object implements Externalizable, Streamable, Encodable
AnAbstractJmsMessageis a message exchanged between a Joram client and its proxy.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected static intACTIVATE_CONSUMER_REQUESTprotected static intADD_CLIENTID_REPLYprotected static intADD_CLIENTID_REQUESTprotected intclassidprotected static String[]classnamesprotected static intCNX_CLOSE_REPLYprotected static intCNX_CLOSE_REQUESTprotected static intCNX_CONNECT_REPLYprotected static intCNX_CONNECT_REQUESTprotected static intCNX_START_REQUESTprotected static intCNX_STOP_REQUESTprotected static intCOMMIT_REQUESTprotected static intCONSUMER_ACK_REQUESTprotected static intCONSUMER_CLOSE_SUB_REQUESTprotected static intCONSUMER_DENY_REQUESTprotected static intCONSUMER_MESSAGESprotected static intCONSUMER_RECEIVE_REQUESTprotected static intCONSUMER_SET_LIST_REQUESTprotected static intCONSUMER_SUB_REQUESTprotected static intCONSUMER_UNSET_LIST_REQUESTprotected static intCONSUMER_UNSUB_REQUESTprivate static booleanDEBUGprotected static intGET_ADMIN_TOPIC_REPLYprotected static intGET_ADMIN_TOPIC_REQUESTprotected static intJMS_REQUEST_GROUPprivate static Loggerloggerprotected static intMOM_EXCEPTION_REPLYprotected static intNULL_CLASS_IDprotected static intPING_REQUESTprotected static intPRODUCER_MESSAGESprotected static intQBROWSE_REPLYprotected static intQBROWSE_REQUESTprotected static intSERVER_REPLYprotected static intSESS_ACK_REQUESTprotected static intSESS_CREATE_DEST_REPLYprotected static intSESS_CREATE_DEST_REQUESTprotected static intSESS_DENY_REQUESTprotected static intTEMP_DEST_DELETE_REQUESTprotected static intXA_CNX_COMMITprotected static intXA_CNX_PREPAREprotected static intXA_CNX_RECOVER_REPLYprotected static intXA_CNX_RECOVER_REQUESTprotected static intXA_CNX_ROLLBACKprotected static intXXX_SESS_CREATE_TTREQUEST-
Fields inherited from interface fr.dyade.aaa.common.encoding.Encodable
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
-
-
Constructor Summary
Constructors Constructor Description AbstractJmsMessage()Constructs anAbstractJmsMessage.
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract intgetClassId()static AbstractJmsMessageread(InputStream is)voidreadExternal(ObjectInput in)static voidwrite(AbstractJmsMessage msg, OutputStream os)voidwriteExternal(ObjectOutput out)-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface fr.dyade.aaa.common.encoding.Encodable
decode, encode, getEncodableClassId, getEncodedSize
-
Methods inherited from interface fr.dyade.aaa.common.stream.Streamable
readFrom, writeTo
-
-
-
-
Field Detail
-
logger
private static final Logger logger
-
DEBUG
private static final boolean DEBUG
-
NULL_CLASS_ID
protected static final int NULL_CLASS_ID
- See Also:
- Constant Field Values
-
CNX_CONNECT_REQUEST
protected static final int CNX_CONNECT_REQUEST
- See Also:
- Constant Field Values
-
CNX_CONNECT_REPLY
protected static final int CNX_CONNECT_REPLY
- See Also:
- Constant Field Values
-
CNX_START_REQUEST
protected static final int CNX_START_REQUEST
- See Also:
- Constant Field Values
-
CNX_STOP_REQUEST
protected static final int CNX_STOP_REQUEST
- See Also:
- Constant Field Values
-
CNX_CLOSE_REQUEST
protected static final int CNX_CLOSE_REQUEST
- See Also:
- Constant Field Values
-
CNX_CLOSE_REPLY
protected static final int CNX_CLOSE_REPLY
- See Also:
- Constant Field Values
-
PRODUCER_MESSAGES
protected static final int PRODUCER_MESSAGES
- See Also:
- Constant Field Values
-
CONSUMER_RECEIVE_REQUEST
protected static final int CONSUMER_RECEIVE_REQUEST
- See Also:
- Constant Field Values
-
CONSUMER_MESSAGES
protected static final int CONSUMER_MESSAGES
- See Also:
- Constant Field Values
-
CONSUMER_SUB_REQUEST
protected static final int CONSUMER_SUB_REQUEST
- See Also:
- Constant Field Values
-
CONSUMER_UNSUB_REQUEST
protected static final int CONSUMER_UNSUB_REQUEST
- See Also:
- Constant Field Values
-
CONSUMER_ACK_REQUEST
protected static final int CONSUMER_ACK_REQUEST
- See Also:
- Constant Field Values
-
CONSUMER_DENY_REQUEST
protected static final int CONSUMER_DENY_REQUEST
- See Also:
- Constant Field Values
-
SESS_ACK_REQUEST
protected static final int SESS_ACK_REQUEST
- See Also:
- Constant Field Values
-
SESS_DENY_REQUEST
protected static final int SESS_DENY_REQUEST
- See Also:
- Constant Field Values
-
MOM_EXCEPTION_REPLY
protected static final int MOM_EXCEPTION_REPLY
- See Also:
- Constant Field Values
-
SERVER_REPLY
protected static final int SERVER_REPLY
- See Also:
- Constant Field Values
-
ACTIVATE_CONSUMER_REQUEST
protected static final int ACTIVATE_CONSUMER_REQUEST
- See Also:
- Constant Field Values
-
COMMIT_REQUEST
protected static final int COMMIT_REQUEST
- See Also:
- Constant Field Values
-
CONSUMER_CLOSE_SUB_REQUEST
protected static final int CONSUMER_CLOSE_SUB_REQUEST
- See Also:
- Constant Field Values
-
CONSUMER_SET_LIST_REQUEST
protected static final int CONSUMER_SET_LIST_REQUEST
- See Also:
- Constant Field Values
-
CONSUMER_UNSET_LIST_REQUEST
protected static final int CONSUMER_UNSET_LIST_REQUEST
- See Also:
- Constant Field Values
-
GET_ADMIN_TOPIC_REPLY
protected static final int GET_ADMIN_TOPIC_REPLY
- See Also:
- Constant Field Values
-
GET_ADMIN_TOPIC_REQUEST
protected static final int GET_ADMIN_TOPIC_REQUEST
- See Also:
- Constant Field Values
-
JMS_REQUEST_GROUP
protected static final int JMS_REQUEST_GROUP
- See Also:
- Constant Field Values
-
PING_REQUEST
protected static final int PING_REQUEST
- See Also:
- Constant Field Values
-
QBROWSE_REPLY
protected static final int QBROWSE_REPLY
- See Also:
- Constant Field Values
-
QBROWSE_REQUEST
protected static final int QBROWSE_REQUEST
- See Also:
- Constant Field Values
-
SESS_CREATE_DEST_REPLY
protected static final int SESS_CREATE_DEST_REPLY
- See Also:
- Constant Field Values
-
SESS_CREATE_DEST_REQUEST
protected static final int SESS_CREATE_DEST_REQUEST
- See Also:
- Constant Field Values
-
XXX_SESS_CREATE_TTREQUEST
protected static final int XXX_SESS_CREATE_TTREQUEST
- See Also:
- Constant Field Values
-
TEMP_DEST_DELETE_REQUEST
protected static final int TEMP_DEST_DELETE_REQUEST
- See Also:
- Constant Field Values
-
XA_CNX_COMMIT
protected static final int XA_CNX_COMMIT
- See Also:
- Constant Field Values
-
XA_CNX_PREPARE
protected static final int XA_CNX_PREPARE
- See Also:
- Constant Field Values
-
XA_CNX_RECOVER_REPLY
protected static final int XA_CNX_RECOVER_REPLY
- See Also:
- Constant Field Values
-
XA_CNX_RECOVER_REQUEST
protected static final int XA_CNX_RECOVER_REQUEST
- See Also:
- Constant Field Values
-
XA_CNX_ROLLBACK
protected static final int XA_CNX_ROLLBACK
- See Also:
- Constant Field Values
-
ADD_CLIENTID_REQUEST
protected static final int ADD_CLIENTID_REQUEST
- See Also:
- Constant Field Values
-
ADD_CLIENTID_REPLY
protected static final int ADD_CLIENTID_REPLY
- See Also:
- Constant Field Values
-
classid
protected int classid
-
classnames
protected static final String[] classnames
-
-
Method Detail
-
getClassId
protected abstract int getClassId()
-
writeExternal
public final void writeExternal(ObjectOutput out) throws IOException
- Specified by:
writeExternalin interfaceExternalizable- Throws:
IOException
-
readExternal
public final void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
- Specified by:
readExternalin interfaceExternalizable- Throws:
IOExceptionClassNotFoundException
-
write
public static void write(AbstractJmsMessage msg, OutputStream os) throws IOException
- Throws:
IOException
-
read
public static AbstractJmsMessage read(InputStream is) throws IOException, ClassNotFoundException, InstantiationException, IllegalAccessException
-
-