diff --git a/fairmq/FairMQTransportFactory.cxx b/fairmq/FairMQTransportFactory.cxx new file mode 100644 index 00000000..331cb10c --- /dev/null +++ b/fairmq/FairMQTransportFactory.cxx @@ -0,0 +1,6 @@ +/** + * FairMQTransportFactory.cxx + * + * @since 2014-01-20 + * @author: A. Rybalchenko + */ \ No newline at end of file diff --git a/fairmq/FairMQTransportFactory.h b/fairmq/FairMQTransportFactory.h new file mode 100644 index 00000000..50178fda --- /dev/null +++ b/fairmq/FairMQTransportFactory.h @@ -0,0 +1,23 @@ +/** + * FairMQTransportFactory.h + * + * @since 2014-01-20 + * @author: A. Rybalchenko + */ + +#ifndef FAIRMQTRANSPORTFACTORY_H_ +#define FAIRMQTRANSPORTFACTORY_H_ + +#include "FairMQMessage.h" +#include "FairMQSocket.h" + +class FairMQTransportFactory +{ + public: + virtual FairMQMessage* CreateMessage() = 0; + virtual FairMQSocket* CreateSocket(FairMQContext* context, int type, int num) = 0; + + virtual ~FairMQTransportFactory() {}; +}; + +#endif /* FAIRMQTRANSPORTFACTORY_H_ */ diff --git a/fairmq/FairMQTransportFactoryZMQ.cxx b/fairmq/FairMQTransportFactoryZMQ.cxx new file mode 100644 index 00000000..87d3bef6 --- /dev/null +++ b/fairmq/FairMQTransportFactoryZMQ.cxx @@ -0,0 +1,23 @@ +/** + * FairMQTransportFactoryZMQ.cxx + * + * @since 2014-01-20 + * @author: A. Rybalchenko + */ + +#include "FairMQTransportFactoryZMQ.h" + +FairMQTransportFactoryZMQ::FairMQTransportFactoryZMQ() +{ + +} + +FairMQMessage* FairMQTransportFactoryZMQ::CreateMessage() +{ + return new FairMQMessageZMQ(); +} + +FairMQSocket* FairMQTransportFactoryZMQ::CreateSocket(FairMQContext* context, int type, int num) +{ + return new FairMQSocketZMQ(context, type, num); +} \ No newline at end of file diff --git a/fairmq/FairMQTransportFactoryZMQ.h b/fairmq/FairMQTransportFactoryZMQ.h new file mode 100644 index 00000000..d90760b1 --- /dev/null +++ b/fairmq/FairMQTransportFactoryZMQ.h @@ -0,0 +1,27 @@ +/** + * FairMQTransportFactoryZMQ.h + * + * @since 2014-01-20 + * @author: A. Rybalchenko + */ + +#ifndef FAIRMQTRANSPORTFACTORYZMQ_H_ +#define FAIRMQTRANSPORTFACTORYZMQ_H_ + +#include "FairMQTransportFactory.h" +#include "FairMQContext.h" +#include "FairMQMessageZMQ.h" +#include "FairMQSocketZMQ.h" + +class FairMQTransportFactoryZMQ : public FairMQTransportFactory +{ + public: + FairMQTransportFactoryZMQ(); + + virtual FairMQMessage* CreateMessage(); + virtual FairMQSocket* CreateSocket(FairMQContext* context, int type, int num); + + virtual ~FairMQTransportFactoryZMQ() {}; +}; + +#endif /* FAIRMQTRANSPORTFACTORYZMQ_H_ */