18#ifndef _CMS_MESSAGECONSUMER_H_
19#define _CMS_MESSAGECONSUMER_H_
Interface for a class that implements the close method.
Definition Closeable.h:35
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
virtual ~MessageConsumer()
virtual cms::MessageAvailableListener * getMessageAvailableListener() const =0
Gets the MessageAvailableListener that this class will send mew Message notification events to.
virtual Message * receive(int millisecs)=0
Synchronously Receive a Message, time out after defined interval.
virtual cms::MessageTransformer * getMessageTransformer() const =0
Gets the currently configured MessageTransformer for this MessageConsumer.
virtual void setMessageListener(MessageListener *listener)=0
Sets the MessageListener that this class will send notifs on.
virtual Message * receive()=0
Synchronously Receive a Message.
virtual std::string getMessageSelector() const =0
Gets this message consumer's message selector expression.
virtual Message * receiveNoWait()=0
Receive a Message, does not wait if there isn't a new message to read, returns NULL if nothing read.
virtual MessageListener * getMessageListener() const =0
Gets the MessageListener that this class will send mew Message notification events to.
virtual void setMessageTransformer(cms::MessageTransformer *transformer)=0
Set an MessageTransformer instance that is applied to all cms::Message objects before they are dispat...
virtual void setMessageAvailableListener(cms::MessageAvailableListener *listener)=0
Sets the MessageAvailableListener that this class will send events to if the consumer is in synchrono...
Root of all messages.
Definition Message.h:88
A MessageListener object is used to receive asynchronously delivered messages.
Definition MessageListener.h:33
Interface for a class that implements the start method.
Definition Startable.h:36
Interface for a class that implements the stop method.
Definition Stoppable.h:36
#define CMS_API
Definition Config.h:31
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition DestinationResolver.h:23