18#ifndef _ACTIVEMQ_CORE_FIFOMESSAGEDISPATCHCHANNEL_H_
19#define _ACTIVEMQ_CORE_FIFOMESSAGEDISPATCHCHANNEL_H_
40 FifoMessageDispatchChannel(
const FifoMessageDispatchChannel&);
41 FifoMessageDispatchChannel& operator=(
const FifoMessageDispatchChannel&);
79 virtual std::vector<Pointer<MessageDispatch> >
removeAll();
88 return channel.tryLock();
99 virtual void wait(
long long millisecs) {
100 channel.wait(millisecs);
103 virtual void wait(
long long millisecs,
int nanos) {
104 channel.wait(millisecs, nanos);
#define AMQCPP_API
Definition Config.h:30
virtual bool isEmpty() const
virtual void enqueue(const Pointer< MessageDispatch > &message)
Add a Message to the Channel behind all pending message.
virtual void wait(long long millisecs, int nanos)
Waits on a signal from this object, which is generated by a call to Notify.
Definition FifoMessageDispatchChannel.h:103
virtual std::vector< Pointer< MessageDispatch > > removeAll()
Remove all messages that are currently in the Channel and return them as a list of Messages.
virtual bool tryLock()
Attempts to Lock the object, if the lock is already held by another thread than this method returns f...
Definition FifoMessageDispatchChannel.h:87
virtual Pointer< MessageDispatch > peek() const
Peek in the Queue and return the first message in the Channel without removing it from the channel.
virtual void wait()
Waits on a signal from this object, which is generated by a call to Notify.
Definition FifoMessageDispatchChannel.h:95
virtual bool isRunning() const
Definition FifoMessageDispatchChannel.h:59
virtual ~FifoMessageDispatchChannel()
virtual void stop()
Stops dispatch of message from the Channel.
virtual void unlock()
Unlocks the object.
Definition FifoMessageDispatchChannel.h:91
virtual bool isClosed() const
Definition FifoMessageDispatchChannel.h:55
virtual Pointer< MessageDispatch > dequeue(long long timeout)
Used to get an enqueued message.
virtual void notifyAll()
Signals the waiters on this object that it can now wake up and continue.
Definition FifoMessageDispatchChannel.h:111
virtual void notify()
Signals a waiter on this object that it can now wake up and continue.
Definition FifoMessageDispatchChannel.h:107
virtual Pointer< MessageDispatch > dequeueNoWait()
Used to get an enqueued message if there is one queued right now.
virtual void wait(long long millisecs)
Waits on a signal from this object, which is generated by a call to Notify.
Definition FifoMessageDispatchChannel.h:99
virtual void start()
Starts dispatch of messages from the Channel.
virtual void enqueueFirst(const Pointer< MessageDispatch > &message)
Add a message to the front of the Channel.
virtual void lock()
Locks the object.
Definition FifoMessageDispatchChannel.h:83
FifoMessageDispatchChannel()
virtual void close()
Close this channel no messages will be dispatched after this method is called.
virtual void clear()
Clear the Channel, all pending messages are removed.
Definition MessageDispatchChannel.h:34
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
A complete implementation of the List interface using a doubly linked list data structure.
Definition LinkedList.h:55
Definition ActiveMQTempDestination.h:29
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24