Package | Description |
---|---|
org.ow2.joram.mom.amqp | |
org.ow2.joram.mom.amqp.marshalling |
Modifier and Type | Method and Description |
---|---|
protected void |
Proxy.doProcessMethod(AbstractMarshallingMethod method) |
private void |
AMQPConnectionListener.doProcessMethod(AbstractMarshallingMethod method,
int channelNumber) |
private static Object |
StubAgentIn.doProcessMethod(AbstractMarshallingMethod method,
short serverId,
long proxyId) |
void |
Proxy.send(AbstractMarshallingMethod method) |
private void |
AMQPConnectionListener.sendMethodToPeer(AbstractMarshallingMethod method,
int channelNumber) |
private void |
AMQPConnectionListener.sendToProxy(AbstractMarshallingMethod method) |
Modifier and Type | Class and Description |
---|---|
static class |
AMQP.Basic.Ack
This method acknowledges one or more messages delivered via the Deliver
or Get-Ok methods.
|
static class |
AMQP.Basic.Cancel
This method cancels a consumer.
|
static class |
AMQP.Basic.CancelOk
This method confirms that the cancellation was completed.
|
static class |
AMQP.Basic.Consume
This method asks the server to start a "consumer", which is a transient
request for messages from a specific queue.
|
static class |
AMQP.Basic.ConsumeOk
The server provides the client with a consumer tag, which is used by the
client for methods called on the consumer at a later stage.
|
static class |
AMQP.Basic.Deliver
This method delivers a message to the client, via a consumer.
|
static class |
AMQP.Basic.Get
This method provides a direct access to the messages in a queue using a
synchronous dialogue that is designed for specific types of application
where synchronous functionality is more important than performance.
|
static class |
AMQP.Basic.GetEmpty
This method tells the client that the queue has no messages available for
the client.
|
static class |
AMQP.Basic.GetOk
This method delivers a message to the client following a get method.
|
static class |
AMQP.Basic.Publish
This method publishes a message to a specific exchange.
|
static class |
AMQP.Basic.Qos
This method requests a specific quality of service.
|
static class |
AMQP.Basic.QosOk
This method tells the client that the requested QoS levels could be
handled by the server.
|
static class |
AMQP.Basic.Recover
This method asks the server to redeliver all unacknowledged messages on a
specified channel.
|
static class |
AMQP.Basic.RecoverAsync
This method asks the server to redeliver all unacknowledged messages on a
specified channel.
|
static class |
AMQP.Basic.RecoverOk
This method acknowledges a Basic.Recover method.
|
static class |
AMQP.Basic.Reject
This method allows a client to reject a message.
|
static class |
AMQP.Basic.Return
This method returns an undeliverable message that was published with the
"immediate" flag set, or an unroutable message published with the
"mandatory" flag set.
|
static class |
AMQP.Channel.Close
This method indicates that the sender wants to close the channel.
|
static class |
AMQP.Channel.CloseOk
This method confirms a Channel.Close method and tells the recipient that it is safe to release resources for the channel.
|
static class |
AMQP.Channel.Flow
This method asks the peer to pause or restart the flow of content data
sent by a consumer.
|
static class |
AMQP.Channel.FlowOk
Confirms to the peer that a flow command was received and processed.
|
static class |
AMQP.Channel.Open
This method opens a channel to the server.
|
static class |
AMQP.Channel.OpenOk
This method signals to the client that the channel is ready for use.
|
static class |
AMQP.Connection.Close
This method indicates that the sender wants to close the connection.
|
static class |
AMQP.Connection.CloseOk
This method confirms a Connection.Close method and tells the recipient
that it is safe to release resources for the connection and close the
socket.
|
static class |
AMQP.Connection.Open
This method opens a connection to a virtual host, which is a collection of resources, and acts to separate multiple application domains within a server.
|
static class |
AMQP.Connection.OpenOk
This method signals to the client that the connection is ready for use.
|
static class |
AMQP.Connection.Secure
The SASL protocol works by exchanging challenges and responses until both peers have received sufficient information to authenticate each other.
|
static class |
AMQP.Connection.SecureOk
This method attempts to authenticate, passing a block of SASL data for the security mechanism at the server side.
|
static class |
AMQP.Connection.Start
This method starts the connection negotiation process by telling the client the protocol version that the server proposes, along with a list of security mechanisms which the client can use for authentication.
|
static class |
AMQP.Connection.StartOk
This method selects a SASL security mechanism.
|
static class |
AMQP.Connection.Tune
This method proposes a set of connection configuration values to the client.
|
static class |
AMQP.Connection.TuneOk
This method sends the client's connection tuning parameters to the server.
|
static class |
AMQP.Exchange.Declare
This method creates an exchange if it does not already exist, and if the
exchange exists, verifies that it is of the correct and expected class.
|
static class |
AMQP.Exchange.DeclareOk
This method confirms a Declare method and confirms the name of the
exchange, essential for automatically-named exchanges.
|
static class |
AMQP.Exchange.Delete
This method deletes an exchange.
|
static class |
AMQP.Exchange.DeleteOk
This method confirms the deletion of an exchange.
|
static class |
AMQP.Queue.Bind
This method binds a queue to an exchange.
|
static class |
AMQP.Queue.BindOk
This method confirms that the bind was successful.
|
static class |
AMQP.Queue.Declare
This method creates or checks a queue.
|
static class |
AMQP.Queue.DeclareOk
This method confirms a Declare method and confirms the name of the queue,
essential for automatically-named queues.
|
static class |
AMQP.Queue.Delete
This method deletes a queue.
|
static class |
AMQP.Queue.DeleteOk
This method confirms the deletion of a queue.
|
static class |
AMQP.Queue.Purge
This method removes all messages from a queue which are not awaiting
acknowledgment.
|
static class |
AMQP.Queue.PurgeOk
This method confirms the purge of a queue.
|
static class |
AMQP.Queue.Unbind
This method unbinds a queue from an exchange.
|
static class |
AMQP.Queue.UnbindOk
This method confirms that the unbind was successful.
|
static class |
AMQP.Tx.Commit
This method commits all message publications and acknowledgments
performed in the current transaction.
|
static class |
AMQP.Tx.CommitOk
This method confirms to the client that the commit succeeded.
|
static class |
AMQP.Tx.Rollback
This method abandons all message publications and acknowledgments
performed in the current transaction.
|
static class |
AMQP.Tx.RollbackOk
This method confirms to the client that the rollback succeeded.
|
static class |
AMQP.Tx.Select
This method sets the channel to use standard transactions.
|
static class |
AMQP.Tx.SelectOk
This method confirms to the client that the channel was successfully set
to use standard transactions.
|
Modifier and Type | Method and Description |
---|---|
static AbstractMarshallingMethod |
AbstractMarshallingMethod.read(byte[] payload) |
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.