Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <LocalQueue.h>
Public Member Functions | |
LocalQueue () | |
Create a local queue. | |
~LocalQueue () | |
bool | get (Message &result, sys::Duration timeout=0) |
Wait up to timeout for the next message from the local queue. | |
Message | get (sys::Duration timeout=sys::TIME_INFINITE) |
Get the next message off the local queue, or wait up to the timeout for message from the broker queue. | |
Message | pop (sys::Duration timeout=sys::TIME_INFINITE) |
Synonym for get(). | |
bool | empty () const |
Return true if local queue is empty. | |
size_t | size () const |
Number of messages on the local queue. |
Create a queue and subscribe it using the SubscriptionManager. Messages from the remote queue on the broker will be stored in the local queue until you retrieve them.
Using a Local Queue
LocalQueue local_queue; subscriptions.subscribe(local_queue, string("message_queue")); for (int i=0; i<10; i++) { Message message = local_queue.get(); std::cout << message.getData() << std::endl; }
Message message = local_queue.get();
// Specifying timeouts (TIME_SEC, TIME_MSEC, TIME_USEC, TIME_NSEC) include <qpid/sys/Time.h> Message message; local_queue.get(message, 5*sys::TIME_SEC);
Definition at line 71 of file LocalQueue.h.
qpid::client::LocalQueue::LocalQueue | ( | ) |
Create a local queue.
Subscribe the local queue to a remote broker queue with a SubscriptionManager.
LocalQueue is an alternative to implementing a MessageListener.
qpid::client::LocalQueue::~LocalQueue | ( | ) |
bool qpid::client::LocalQueue::empty | ( | ) | const |
Return true if local queue is empty.
Message qpid::client::LocalQueue::get | ( | sys::Duration | timeout = sys::TIME_INFINITE |
) |
Get the next message off the local queue, or wait up to the timeout for message from the broker queue.
timeout | wait up this timeout for a message to appear. |
ClosedException | if subscription is closed or timeout exceeded. |
bool qpid::client::LocalQueue::get | ( | Message & | result, | |
sys::Duration | timeout = 0 | |||
) |
Wait up to timeout for the next message from the local queue.
result | Set to the message from the queue. | |
timeout | wait up this timeout for a message to appear. |
Message qpid::client::LocalQueue::pop | ( | sys::Duration | timeout = sys::TIME_INFINITE |
) |
Synonym for get().
size_t qpid::client::LocalQueue::size | ( | ) | const |
Number of messages on the local queue.