LSSTApplications  11.0-13-gbb96280,12.1.rc1,12.1.rc1+1,12.1.rc1+2,12.1.rc1+5,12.1.rc1+8,12.1.rc1-1-g06d7636+1,12.1.rc1-1-g253890b+5,12.1.rc1-1-g3d31b68+7,12.1.rc1-1-g3db6b75+1,12.1.rc1-1-g5c1385a+3,12.1.rc1-1-g83b2247,12.1.rc1-1-g90cb4cf+6,12.1.rc1-1-g91da24b+3,12.1.rc1-2-g3521f8a,12.1.rc1-2-g39433dd+4,12.1.rc1-2-g486411b+2,12.1.rc1-2-g4c2be76,12.1.rc1-2-gc9c0491,12.1.rc1-2-gda2cd4f+6,12.1.rc1-3-g3391c73+2,12.1.rc1-3-g8c1bd6c+1,12.1.rc1-3-gcf4b6cb+2,12.1.rc1-4-g057223e+1,12.1.rc1-4-g19ed13b+2,12.1.rc1-4-g30492a7
LSSTDataManagementBasePackage
EventEnqueuer.h
Go to the documentation of this file.
1 // -*- lsst-c++ -*-
2 
3 /*
4  * LSST Data Management System
5  * Copyright 2008-2016 AURA/LSST.
6  *
7  * This product includes software developed by the
8  * LSST Project (http://www.lsst.org/).
9  *
10  * This program is free software: you can redistribute it and/or modify
11  * it under the terms of the GNU General Public License as published by
12  * the Free Software Foundation, either version 3 of the License, or
13  * (at your option) any later version.
14  *
15  * This program is distributed in the hope that it will be useful,
16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18  * GNU General Public License for more details.
19  *
20  * You should have received a copy of the LSST License Statement and
21  * the GNU General Public License along with this program. If not,
22  * see <https://www.lsstcorp.org/LegalNotices/>.
23  */
24 
33 #ifndef LSST_CTRL_EVENTS_EVENTENQUEUER_H
34 #define LSST_CTRL_EVENTS_EVENTENQUEUER_H
35 
36 #include <activemq/commands/ActiveMQTopic.h>
37 #include <cms/Connection.h>
38 #include <cms/Session.h>
39 #include <cms/TextMessage.h>
40 
41 #include <stdlib.h>
42 #include <iostream>
43 
45 
47 
48 namespace lsst {
49 namespace ctrl {
50 namespace events {
51 
57 class EventEnqueuer : public Transmitter
58 {
59 public:
60 
71  EventEnqueuer(const std::string& hostName, const std::string& destinationName, int hostPort = EventBroker::DEFAULTHOSTPORT);
72 
73  virtual ~EventEnqueuer();
74 
79  std::string getQueueName();
80 
81  virtual std::string getDestinationPropertyName();
82 
83 };
84 }
85 }
86 }
87 
88 
89 #endif /*end LSST_CTRL_EVENTS_EVENTENQUEUER_H*/
std::string getQueueName()
get the queue name
lsst::daf::base::PropertySet PropertySet
Definition: Wcs.cc:59
defines the Transmitter class
Transmit events to the event bus.
Definition: Transmitter.h:59
static const int DEFAULTHOSTPORT
Definition: EventBroker.h:47
Transmit events to the event bus.
Definition: EventEnqueuer.h:57
virtual std::string getDestinationPropertyName()
get the destination property name
EventEnqueuer(const std::string &hostName, const std::string &destinationName, int hostPort=EventBroker::DEFAULTHOSTPORT)
Transmits events to the specified host and queue.