acknowledgeMessage(const ActiveMQMessage *message) | activemq::core::ActiveMQConsumer | [virtual] |
ActiveMQConsumer(connector::ConsumerInfo *consumerInfo, ActiveMQSession *session) | activemq::core::ActiveMQConsumer | |
consumerInfo | activemq::core::ActiveMQConsumer | [private] |
destroyMessage(cms::Message *message) | activemq::core::ActiveMQConsumer | [protected, virtual] |
dispatch(ActiveMQMessage *message) | activemq::core::ActiveMQConsumer | [virtual] |
getConnectorResource(void) | activemq::core::ActiveMQConsumer | [inline, virtual] |
getConsumerInfo(void) | activemq::core::ActiveMQConsumer | [inline, virtual] |
getMessageListener(void) const | activemq::core::ActiveMQConsumer | [inline, virtual] |
getMessageSelector(void) const | activemq::core::ActiveMQConsumer | [virtual] |
listener | activemq::core::ActiveMQConsumer | [private] |
listenerLock | activemq::core::ActiveMQConsumer | [private] |
listenerThread | activemq::core::ActiveMQConsumer | [private] |
msgQueue | activemq::core::ActiveMQConsumer | [private] |
notifyListener(cms::Message *message) | activemq::core::ActiveMQConsumer | [protected] |
onActiveMQMessage(ActiveMQMessage *message) | activemq::core::ActiveMQConsumer | [virtual] |
purgeMessages(void) | activemq::core::ActiveMQConsumer | [protected, virtual] |
receive(void) | activemq::core::ActiveMQConsumer | [virtual] |
receive(int millisecs) | activemq::core::ActiveMQConsumer | [virtual] |
receiveNoWait(void) | activemq::core::ActiveMQConsumer | [virtual] |
run(void) | activemq::core::ActiveMQConsumer | [virtual] |
session | activemq::core::ActiveMQConsumer | [private] |
setMessageListener(cms::MessageListener *listener) | activemq::core::ActiveMQConsumer | [virtual] |
shutdown | activemq::core::ActiveMQConsumer | [private] |
startThread() | activemq::core::ActiveMQConsumer | [protected] |
stopThread() | activemq::core::ActiveMQConsumer | [protected] |
~ActiveMQAckHandler(void) | activemq::core::ActiveMQAckHandler | [inline, virtual] |
~ActiveMQConsumer(void) | activemq::core::ActiveMQConsumer | [virtual] |
~ActiveMQMessageListener(void) | activemq::core::ActiveMQMessageListener | [inline, virtual] |
~ActiveMQSessionResource(void) | activemq::core::ActiveMQSessionResource | [inline, virtual] |
~Runnable() | activemq::concurrent::Runnable | [inline, virtual] |