catapult::zeromq::ZeroMqEntityPublisher::SynchronizedPublisher Class Reference

Public Member Functions
	SynchronizedPublisher (unsigned short port)
	~SynchronizedPublisher ()
void	queue (std::unique_ptr< MessageGroup > &&pMessageGroup)

Private Attributes
zmq::context_t	m_zmqContext
zmq::socket_t	m_zmqSocket
std::unique_ptr< thread::IoThreadPool >	m_pPool

Constructor & Destructor Documentation

SynchronizedPublisher()

catapult::zeromq::ZeroMqEntityPublisher::SynchronizedPublisher::SynchronizedPublisher ( unsigned short  port )

inlineexplicit

~SynchronizedPublisher()

catapult::zeromq::ZeroMqEntityPublisher::SynchronizedPublisher::~SynchronizedPublisher ( )

inline

Member Function Documentation

queue()

void catapult::zeromq::ZeroMqEntityPublisher::SynchronizedPublisher::queue ( std::unique_ptr< MessageGroup > &&  pMessageGroup )

inline

Member Data Documentation

m_pPool

std::unique_ptr<thread::IoThreadPool> catapult::zeromq::ZeroMqEntityPublisher::SynchronizedPublisher::m_pPool

private

m_zmqContext

zmq::context_t catapult::zeromq::ZeroMqEntityPublisher::SynchronizedPublisher::m_zmqContext

private

m_zmqSocket

zmq::socket_t catapult::zeromq::ZeroMqEntityPublisher::SynchronizedPublisher::m_zmqSocket

private

---

The documentation for this class was generated from the following file:

• ZeroMqEntityPublisher.cpp