Package | Description |
---|---|
org.ow2.joram.mom.amqp | |
org.ow2.joram.mom.amqp.marshalling | |
org.ow2.joram.mom.amqp.structures |
Class and Description |
---|
AbstractMarshallingMethod |
AMQP.Basic.Ack
This method acknowledges one or more messages delivered via the Deliver
or Get-Ok methods.
|
AMQP.Basic.BasicProperties |
AMQP.Basic.Consume
This method asks the server to start a "consumer", which is a transient
request for messages from a specific queue.
|
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.
|
AMQP.Basic.Publish
This method publishes a message to a specific exchange.
|
AMQP.Basic.Qos
This method requests a specific quality of service.
|
AMQP.Basic.Reject
This method allows a client to reject a message.
|
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.
|
AMQP.Connection.TuneOk
This method sends the client's connection tuning parameters to the server.
|
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.
|
AMQP.Exchange.Delete
This method deletes an exchange.
|
AMQP.Queue.Bind
This method binds a queue to an exchange.
|
AMQP.Queue.Declare
This method creates or checks a queue.
|
AMQP.Queue.DeclareOk
This method confirms a Declare method and confirms the name of the queue,
essential for automatically-named queues.
|
AMQP.Queue.Delete
This method deletes a queue.
|
AMQP.Queue.DeleteOk
This method confirms the deletion of a queue.
|
AMQP.Queue.Purge
This method removes all messages from a queue which are not awaiting
acknowledgment.
|
AMQP.Queue.PurgeOk
This method confirms the purge of a queue.
|
AMQP.Queue.Unbind
This method unbinds a queue from an exchange.
|
Frame
Represents an AMQP wire-protocol frame:
type, channel, size, payload, end.
|
MarshallingHeader |
Class and Description |
---|
AbstractMarshallingClass |
AbstractMarshallingMethod |
AMQP.Basic.BasicProperties |
AMQPInputStream |
AMQPOutputStream |
Frame
Represents an AMQP wire-protocol frame:
type, channel, size, payload, end.
|
LongString |
MarshallingHeader |
Class and Description |
---|
AMQP.Basic.BasicProperties |
AMQP.Basic.Deliver
This method delivers a message to the client, via a consumer.
|
AMQP.Basic.GetOk
This method delivers a message to the client following a get method.
|
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.
|
Copyright © 2020 ScalAgent D.T.. All rights reserved.