00001 // Copyright CERN 2012 - Developed in collaboration with GSI 00002 #ifndef ON_DEMAND_PRODUCER_IMPL_H 00003 #define ON_DEMAND_PRODUCER_IMPL_H 00004 00005 #include <fesa-core/Core/OnDemandProducer.h> 00006 00007 namespace fesa 00008 { 00009 00010 class AbstractMsgQueue; 00011 class OnDemandMessage; 00012 00013 class OnDemandProducerImpl: public OnDemandProducer 00014 { 00015 public: 00016 00017 OnDemandProducerImpl(AbstractMsgQueue* msgQueue); 00018 virtual ~OnDemandProducerImpl(); 00019 00020 virtual void sendMessage(OnDemandMessage& message); 00021 00022 private: 00023 00024 AbstractMsgQueue* msgQueue_; 00025 }; 00026 00027 } 00028 #endif // ON_DEMAND_PRODUCER_IMPL_H