17#ifndef _ACTIVEMQ_CORE_ACTIVEMQCONSUMER_H_
18#define _ACTIVEMQ_CORE_ACTIVEMQCONSUMER_H_
35 using decaf::lang::Pointer;
38 class ActiveMQConsumerData;
43 ActiveMQConsumerData* config;
47 ActiveMQConsumer(
const ActiveMQConsumer&);
48 ActiveMQConsumer& operator=(
const ActiveMQConsumer&);
#define AMQCPP_API
Definition Config.h:30
virtual ~ActiveMQConsumer()
void setOptimizeAcknowledge(bool value)
Enable or disable optimized acknowledge for this consumer.
virtual void close()
Closes this object and deallocates the appropriate resources.
virtual void setMessageListener(cms::MessageListener *listener)
Sets the MessageListener that this class will send notifs on.
virtual void stop()
Stops this service.
virtual cms::Message * receiveNoWait()
Receive a Message, does not wait if there isn't a new message to read, returns NULL if nothing read.
virtual void setMessageAvailableListener(cms::MessageAvailableListener *listener)
Sets the MessageAvailableListener that this class will send events to if the consumer is in synchrono...
long long getOptimizedAckScheduledAckInterval() const
Time in Milliseconds before an automatic acknowledge is done for any outstanding delivered Messages.
bool isOptimizeAcknowledge() const
virtual void start()
Starts the service.
RedeliveryPolicy * getRedeliveryPolicy() const
Gets a pointer to this Consumer's Redelivery Policy object, the Consumer retains ownership of this po...
virtual cms::MessageListener * getMessageListener() const
Gets the MessageListener that this class will send mew Message notification events to.
void setOptimizedAckScheduledAckInterval(long long value)
Sets the time in Milliseconds to schedule an automatic acknowledge of outstanding messages when optim...
void setRedeliveryPolicy(RedeliveryPolicy *policy)
Sets the RedeliveryPolicy this Consumer should use when a rollback is performed on a transacted Consu...
virtual void setMessageTransformer(cms::MessageTransformer *transformer)
Set an MessageTransformer instance that is applied to all cms::Message objects before they are dispat...
virtual cms::MessageAvailableListener * getMessageAvailableListener() const
Gets the MessageAvailableListener that this class will send mew Message notification events to.
ActiveMQConsumer(const Pointer< activemq::core::kernels::ActiveMQConsumerKernel > &kernel)
Create a new ActiveMQConsumer that contains the pointer to the Kernel that implement the real Message...
decaf::lang::Exception * getFailureError() const
Gets the error that caused this Consumer to be in a Failed state, or NULL if there is no Error.
virtual std::string getMessageSelector() const
Gets this message consumer's message selector expression.
const Pointer< commands::ConsumerInfo > & getConsumerInfo() const
Get the Consumer information for this consumer.
const Pointer< commands::ConsumerId > & getConsumerId() const
Get the Consumer Id for this consumer.
virtual cms::Message * receive(int millisecs)
Synchronously Receive a Message, time out after defined interval.
virtual cms::MessageTransformer * getMessageTransformer() const
Gets the currently configured MessageTransformer for this MessageConsumer.
virtual cms::Message * receive()
Synchronously Receive a Message.
int getMessageAvailableCount() const
Definition ActiveMQSession.h:42
Interface for a RedeliveryPolicy object that controls how message Redelivery is handled in ActiveMQ-C...
Definition RedeliveryPolicy.h:34
A listener interface similar to the MessageListener interface.
Definition MessageAvailableListener.h:33
A client uses a MessageConsumer to received messages from a destination.
Definition MessageConsumer.h:63
Root of all messages.
Definition Message.h:88
A MessageListener object is used to receive asynchronously delivered messages.
Definition MessageListener.h:33
Definition Exception.h:38
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
Definition ActiveMQTempDestination.h:29
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24