public class AMQP extends Object
Modifier and Type | Class and Description |
---|---|
static class |
AMQP.Basic |
static class |
AMQP.Channel |
static class |
AMQP.Connection |
static class |
AMQP.Exchange |
static class |
AMQP.PROTOCOL |
static class |
AMQP.Queue |
static class |
AMQP.Tx |
Modifier and Type | Field and Description |
---|---|
static int |
ACCESS_REFUSED |
static int |
CHANNEL_ERROR |
static int |
CLASS_BASIC
The Basic class provides methods that support an industry-standard messaging model.
|
static 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.
|
static 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.
|
static int |
CLASS_EXCHANGE
Exchanges match and distribute messages across queues.
|
static int |
CLASS_QUEUE
Queues store and forward messages.
|
static int |
CLASS_TX
The Tx class allows publish and ack operations to be batched into atomic
units of work.
|
static AbstractMarshallingClass[] |
classes |
static int |
COMMAND_INVALID |
static int |
CONNECTION_FORCED |
static int |
CONTENT_TOO_LARGE |
static int |
FRAME_BODY |
static int |
FRAME_END |
static int |
FRAME_ERROR |
static int |
FRAME_HEADER |
static int |
FRAME_HEARTBEAT |
static int |
FRAME_METHOD |
static int |
FRAME_MIN_SIZE |
static int[] |
ids |
static int |
INTERNAL_ERROR |
static int |
INVALID_PATH |
static int |
NO_CONSUMERS |
static int |
NOT_ALLOWED |
static int |
NOT_FOUND |
static int |
NOT_IMPLEMENTED |
static int |
PRECONDITION_FAILED |
static int |
REPLY_SUCCESS |
static int |
RESOURCE_ERROR |
static int |
RESOURCE_LOCKED |
static int |
SYNTAX_ERROR |
static int |
UNEXPECTED_FRAME |
Constructor and Description |
---|
AMQP() |
Modifier and Type | Method and Description |
---|---|
static AbstractMarshallingClass |
getAmqpClass(int id) |
private static int |
getPosition(int id) |
public static final int CLASS_CONNECTION
public static final int CLASS_CHANNEL
public static final int CLASS_EXCHANGE
public static final int CLASS_QUEUE
public static final int CLASS_BASIC
public static final int CLASS_TX
public static final int[] ids
public static final AbstractMarshallingClass[] classes
public static final int FRAME_METHOD
public static final int FRAME_HEADER
public static final int FRAME_BODY
public static final int FRAME_HEARTBEAT
public static final int FRAME_MIN_SIZE
public static final int FRAME_END
public static final int REPLY_SUCCESS
public static final int CONTENT_TOO_LARGE
public static final int NO_CONSUMERS
public static final int CONNECTION_FORCED
public static final int INVALID_PATH
public static final int ACCESS_REFUSED
public static final int NOT_FOUND
public static final int RESOURCE_LOCKED
public static final int PRECONDITION_FAILED
public static final int FRAME_ERROR
public static final int SYNTAX_ERROR
public static final int COMMAND_INVALID
public static final int CHANNEL_ERROR
public static final int UNEXPECTED_FRAME
public static final int RESOURCE_ERROR
public static final int NOT_ALLOWED
public static final int NOT_IMPLEMENTED
public static final int INTERNAL_ERROR
private static int getPosition(int id)
public static AbstractMarshallingClass getAmqpClass(int id)
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.