Class | Qpid::Messaging::Session |
In: |
lib/qpid_messaging/session.rb
|
Parent: | Object |
A Session represents a distinct conversation between end points.
Acknowledges one or more outstanding messages that have been received on this session.
session.acknowledge # acknowledges all received messages session.acknowledge :message => message # acknowledge one message session.acknowledge :sync => true # blocks until the call completes
Closes the Session and all associated Sender and Receiver instances.
NOTE: All Session instances for a Connection are closed when the Connection is closed.
Creates a new endpoint for receiving messages.
The address can either be an instance Address or else a string that describes an address endpoint.
receiver = session.create_receiver "my-queue"
Creates a new endpoint for sending messages.
The address can either be an instance Address or else a string that describes an address endpoint.
sender = session.create_sender "my-queue;{create:always}"
If the Session has been rendered invalid due to some exception, this method will result in that exception being raised.
If none have occurred, then no exceptions are raised.
if @session.errors? begin @session.errors rescue Exception => error puts "An error occurred: #{error}" end end
Returns true if there were exceptions on this session.
puts "There were session errors." if @session.errors?
Fetches the Receiver for the next message.
recv = session.next_receiver # wait forever for the next +Receiver+ # execute a block on the next receiver session.next_receiver do |recv| msg = recv.get puts "Received message: #{msg.content}" end
Returns the total number of receivable messages, and messages already received, by Receiver instances associated with this Session.
Retrieves the Receiver with the specified name.
The Receiver must have been previously created using the create_receiver method.
receiver = session.receiver "my-queue"
Rejects the specified message. A rejected message will not be redelivered.
NOTE: A message cannot be rejected once it has been acknowledged.
Releases the message, which allows the broker to attempt to redeliver it.
NOTE: A message connot be released once it has been acknowled.
Retrieves the Sender with the specified name.
The Sender must have been previously created using the create_sender method.
sender = session.sender "my-queue"
Requests synchronization with the server.