18#ifndef _ACTIVEMQ_CORE_MESSAGEDISPATCHCHANNEL_H_
19#define _ACTIVEMQ_CORE_MESSAGEDISPATCHCHANNEL_H_
31 using decaf::lang::Pointer;
32 using activemq::commands::MessageDispatch;
128 virtual std::vector<Pointer<MessageDispatch> >
removeAll() = 0;
#define AMQCPP_API
Definition Config.h:30
Definition MessageDispatchChannel.h:34
virtual void enqueue(const Pointer< MessageDispatch > &message)=0
Add a Message to the Channel behind all pending message.
virtual ~MessageDispatchChannel()
virtual bool isClosed() const =0
virtual Pointer< MessageDispatch > peek() const =0
Peek in the Queue and return the first message in the Channel without removing it from the channel.
virtual std::vector< Pointer< MessageDispatch > > removeAll()=0
Remove all messages that are currently in the Channel and return them as a list of Messages.
virtual Pointer< MessageDispatch > dequeueNoWait()=0
Used to get an enqueued message if there is one queued right now.
virtual void enqueueFirst(const Pointer< MessageDispatch > &message)=0
Add a message to the front of the Channel.
virtual void start()=0
Starts dispatch of messages from the Channel.
virtual Pointer< MessageDispatch > dequeue(long long timeout)=0
Used to get an enqueued message.
virtual void clear()=0
Clear the Channel, all pending messages are removed.
virtual void stop()=0
Stops dispatch of message from the Channel.
virtual bool isRunning() const =0
virtual int size() const =0
virtual bool isEmpty() const =0
virtual void close()=0
Close this channel no messages will be dispatched after this method is called.
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
The interface for all synchronizable objects (that is, objects that can be locked and unlocked).
Definition Synchronizable.h:37
Definition ActiveMQTempDestination.h:29
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24