CZMQRingItemSourceThread

Name

CZMQRingItemSourceThread -- Provide a thread that routes ring items from a source

Synopsis


#include <CZMQRingItemSourceThread.h>
class CZMQRingItemSourceThread : public CThreadedProcessingElement
{
public:
    CZMQRingItemSourceThread(const char* ringUri, const char* routerUri);

};

        

DESCRIPTION

Provides a thread that takes ring items from some data source specified by ringUri and, using the ZeroMQ Router/Dealer pattern ROUTER running on routerUri fans them out as work items for parallel processing.