18#ifndef _ACTIVEMQ_CORE_ACTIVEMQQUEUEBROWSER_H_
19#define _ACTIVEMQ_CORE_ACTIVEMQQUEUEBROWSER_H_
68 ActiveMQQueueBrowser(
const ActiveMQQueueBrowser&);
69 ActiveMQQueueBrowser& operator=(
const ActiveMQQueueBrowser&);
76 const std::string& selector,
98 void notifyMessageAvailable();
99 void waitForMessageAvailable();
102 void destroyConsumer();
#define AMQCPP_API
Definition Config.h:30
virtual bool hasMoreMessages()
Returns true if there are more Message in the Browser that can be retrieved via the nextMessage metho...
virtual cms::MessageEnumeration * getEnumeration()
Gets a pointer to an Enumeration object for browsing the Messages currently in the Queue in the order...
ActiveMQQueueBrowser(activemq::core::kernels::ActiveMQSessionKernel *session, const Pointer< commands::ConsumerId > &consumerId, const Pointer< commands::ActiveMQDestination > &destination, const std::string &selector, bool dispatchAsync)
virtual std::string getMessageSelector() const
virtual cms::Message * nextMessage()
Returns the Next Message in the Queue if one is present, if no more Message's are available then an E...
virtual ~ActiveMQQueueBrowser()
virtual const cms::Queue * getQueue() const
friend class Browser
Definition ActiveMQQueueBrowser.h:50
virtual void close()
Closes this object and deallocates the appropriate resources.
Definition ActiveMQSession.h:42
Definition ActiveMQConsumerKernel.h:49
Definition ActiveMQSessionKernel.h:67
Defines an object that enumerates a collection of Messages.
Definition MessageEnumeration.h:35
Root of all messages.
Definition Message.h:88
This class implements in interface for browsing the messages in a Queue without removing them.
Definition QueueBrowser.h:53
An interface encapsulating a provider-specific queue name.
Definition Queue.h:37
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
Mutex object that offers recursive support on all platforms as well as providing the ability to use t...
Definition Mutex.h:39
A boolean value that may be updated atomically.
Definition AtomicBoolean.h:34
Definition ActiveMQQueueBrowser.h:37
Definition ActiveMQTempDestination.h:29
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24