#ifndef QPID_BROKER_QUEUEEVENTS_H #define QPID_BROKER_QUEUEEVENTS_H /* * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * */ #include "qpid/broker/BrokerImportExport.h" #include "qpid/broker/QueuedMessage.h" #include "qpid/sys/Mutex.h" #include "qpid/sys/PollableQueue.h" #include #include #include namespace qpid { namespace broker { /** * Event manager for queue events. Allows queues to indicate when * events have occured; allows listeners to register for notification * of this. The notification happens asynchronously, in a separate * thread. */ class QueueEvents { public: enum EventType {ENQUEUE, DEQUEUE}; struct Event { EventType type; QueuedMessage msg; QPID_BROKER_EXTERN Event(EventType, const QueuedMessage&); }; typedef boost::function EventListener; QPID_BROKER_EXTERN QueueEvents(const boost::shared_ptr& poller, bool isSync = false); QPID_BROKER_EXTERN ~QueueEvents(); QPID_BROKER_EXTERN void enqueued(const QueuedMessage&); QPID_BROKER_EXTERN void dequeued(const QueuedMessage&); QPID_BROKER_EXTERN void registerListener(const std::string& id, const EventListener&); QPID_BROKER_EXTERN void unregisterListener(const std::string& id); void enable(); void disable(); //process all outstanding events QPID_BROKER_EXTERN void shutdown(); QPID_BROKER_EXTERN bool isSync(); private: typedef qpid::sys::PollableQueue EventQueue; typedef std::map Listeners; EventQueue eventQueue; Listeners listeners; volatile bool enabled; qpid::sys::Mutex lock;//protect listeners from concurrent access bool sync; EventQueue::Batch::const_iterator handle(const EventQueue::Batch& e); }; }} // namespace qpid::broker #endif /*!QPID_BROKER_QUEUEEVENTS_H*/