Class AMQP
- java.lang.Object
-
- org.ow2.joram.mom.amqp.marshalling.AMQP
-
public class AMQP extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classAMQP.Basicstatic classAMQP.Channelstatic classAMQP.Connectionstatic classAMQP.Exchangestatic classAMQP.PROTOCOLstatic classAMQP.Queuestatic classAMQP.Tx
-
Field Summary
Fields Modifier and Type Field Description static intACCESS_REFUSEDstatic intCHANNEL_ERRORstatic intCLASS_BASICThe Basic class provides methods that support an industry-standard messaging model.static intCLASS_CHANNELThe channel class provides methods for a client to establish a channel to a server and for both peers to operate the channel thereafter.static intCLASS_CONNECTIONThe connection class provides methods for a client to establish a network connection to a server, and for both peers to operate the connection thereafter.static intCLASS_EXCHANGEExchanges match and distribute messages across queues.static intCLASS_QUEUEQueues store and forward messages.static intCLASS_TXThe Tx class allows publish and ack operations to be batched into atomic units of work.static AbstractMarshallingClass[]classesstatic intCOMMAND_INVALIDstatic intCONNECTION_FORCEDstatic intCONTENT_TOO_LARGEstatic intFRAME_BODYstatic intFRAME_ENDstatic intFRAME_ERRORstatic intFRAME_HEADERstatic intFRAME_HEARTBEATstatic intFRAME_METHODstatic intFRAME_MIN_SIZEstatic int[]idsstatic intINTERNAL_ERRORstatic intINVALID_PATHstatic intNO_CONSUMERSstatic intNOT_ALLOWEDstatic intNOT_FOUNDstatic intNOT_IMPLEMENTEDstatic intPRECONDITION_FAILEDstatic intREPLY_SUCCESSstatic intRESOURCE_ERRORstatic intRESOURCE_LOCKEDstatic intSYNTAX_ERRORstatic intUNEXPECTED_FRAME
-
Constructor Summary
Constructors Constructor Description AMQP()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static AbstractMarshallingClassgetAmqpClass(int id)private static intgetPosition(int id)
-
-
-
Field Detail
-
CLASS_CONNECTION
public static final int CLASS_CONNECTION
The connection class provides methods for a client to establish a network connection to a server, and for both peers to operate the connection thereafter.- See Also:
- Constant Field Values
-
CLASS_CHANNEL
public static final int CLASS_CHANNEL
The channel class provides methods for a client to establish a channel to a server and for both peers to operate the channel thereafter.- See Also:
- Constant Field Values
-
CLASS_EXCHANGE
public static final int CLASS_EXCHANGE
Exchanges match and distribute messages across queues. Exchanges can be configured in the server or declared at runtime.- See Also:
- Constant Field Values
-
CLASS_QUEUE
public static final int CLASS_QUEUE
Queues store and forward messages. Queues can be configured in the server or created at runtime. Queues must be attached to at least one exchange in order to receive messages from publishers.- See Also:
- Constant Field Values
-
CLASS_BASIC
public static final int CLASS_BASIC
The Basic class provides methods that support an industry-standard messaging model.- See Also:
- Constant Field Values
-
CLASS_TX
public static final int CLASS_TX
The Tx class allows publish and ack operations to be batched into atomic units of work. The intention is that all publish and ack requests issued within a transaction will complete successfully or none of them will. Servers SHOULD implement atomic transactions at least where all publish or ack requests affect a single queue. Transactions that cover multiple queues may be non-atomic, given that queues can be created and destroyed asynchronously, and such events do not form part of any transaction. Further, the behaviour of transactions with respect to the immediate and mandatory flags on Basic.Publish methods is not defined.- See Also:
- Constant Field Values
-
ids
public static final int[] ids
-
classes
public static final AbstractMarshallingClass[] classes
-
FRAME_METHOD
public static final int FRAME_METHOD
- See Also:
- Constant Field Values
-
FRAME_HEADER
public static final int FRAME_HEADER
- See Also:
- Constant Field Values
-
FRAME_BODY
public static final int FRAME_BODY
- See Also:
- Constant Field Values
-
FRAME_HEARTBEAT
public static final int FRAME_HEARTBEAT
- See Also:
- Constant Field Values
-
FRAME_MIN_SIZE
public static final int FRAME_MIN_SIZE
- See Also:
- Constant Field Values
-
FRAME_END
public static final int FRAME_END
- See Also:
- Constant Field Values
-
REPLY_SUCCESS
public static final int REPLY_SUCCESS
- See Also:
- Constant Field Values
-
CONTENT_TOO_LARGE
public static final int CONTENT_TOO_LARGE
- See Also:
- Constant Field Values
-
NO_CONSUMERS
public static final int NO_CONSUMERS
- See Also:
- Constant Field Values
-
CONNECTION_FORCED
public static final int CONNECTION_FORCED
- See Also:
- Constant Field Values
-
INVALID_PATH
public static final int INVALID_PATH
- See Also:
- Constant Field Values
-
ACCESS_REFUSED
public static final int ACCESS_REFUSED
- See Also:
- Constant Field Values
-
NOT_FOUND
public static final int NOT_FOUND
- See Also:
- Constant Field Values
-
RESOURCE_LOCKED
public static final int RESOURCE_LOCKED
- See Also:
- Constant Field Values
-
PRECONDITION_FAILED
public static final int PRECONDITION_FAILED
- See Also:
- Constant Field Values
-
FRAME_ERROR
public static final int FRAME_ERROR
- See Also:
- Constant Field Values
-
SYNTAX_ERROR
public static final int SYNTAX_ERROR
- See Also:
- Constant Field Values
-
COMMAND_INVALID
public static final int COMMAND_INVALID
- See Also:
- Constant Field Values
-
CHANNEL_ERROR
public static final int CHANNEL_ERROR
- See Also:
- Constant Field Values
-
UNEXPECTED_FRAME
public static final int UNEXPECTED_FRAME
- See Also:
- Constant Field Values
-
RESOURCE_ERROR
public static final int RESOURCE_ERROR
- See Also:
- Constant Field Values
-
NOT_ALLOWED
public static final int NOT_ALLOWED
- See Also:
- Constant Field Values
-
NOT_IMPLEMENTED
public static final int NOT_IMPLEMENTED
- See Also:
- Constant Field Values
-
INTERNAL_ERROR
public static final int INTERNAL_ERROR
- See Also:
- Constant Field Values
-
-
Method Detail
-
getPosition
private static int getPosition(int id)
-
getAmqpClass
public static AbstractMarshallingClass getAmqpClass(int id)
-
-