mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-12-14 15:00:17 +00:00
add factory classes
This commit is contained in:
6
fairmq/FairMQTransportFactory.cxx
Normal file
6
fairmq/FairMQTransportFactory.cxx
Normal file
@@ -0,0 +1,6 @@
|
|||||||
|
/**
|
||||||
|
* FairMQTransportFactory.cxx
|
||||||
|
*
|
||||||
|
* @since 2014-01-20
|
||||||
|
* @author: A. Rybalchenko
|
||||||
|
*/
|
||||||
23
fairmq/FairMQTransportFactory.h
Normal file
23
fairmq/FairMQTransportFactory.h
Normal file
@@ -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_ */
|
||||||
23
fairmq/FairMQTransportFactoryZMQ.cxx
Normal file
23
fairmq/FairMQTransportFactoryZMQ.cxx
Normal file
@@ -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);
|
||||||
|
}
|
||||||
27
fairmq/FairMQTransportFactoryZMQ.h
Normal file
27
fairmq/FairMQTransportFactoryZMQ.h
Normal file
@@ -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_ */
|
||||||
Reference in New Issue
Block a user