Using Reusable ZeroMQ C Helpers

Posted on July 2, 2013 by Matt McKnight — Leave a comment

Now it’s really easy to throw data around using the 0MQ helpers written up before!

Subscribe

	void SubscribeCallback(uint8_t *buf, int size)
	{
	//do whatever with the payload received
	}

	//set up the subscribe thread
	SubscribeZeroMQDataThreadArgs *subscribeThread = StartSubscribe(zmqContext, "tcp://hostname:port", "topic", SubscribeCallback, "LogCategory");

	//shutdown the subscribe thread later
	StopSubscribe(subscribeThread);

view raw

Using0MQSubscribe.c

hosted with ❤ by GitHub

Request Reply

	static RequestReplyZeroMQReply* RequestReplyCallback(const char request, const void argument, const uint8_t *data, const int size)
	{
	RequestReplyZeroMQReply *reply = malloc(sizeof(RequestReplyZeroMQReply));

	someData_t *someData;
	int len = get_some_data_to_return(&someData, data, size);
	reply->data = someData;
	reply->size = len;

	return reply;
	}

	//set up the request reply thread
	//NULL could be a pointer to a variable you'd like passed to the callback
	RequestReplyZeroMQThreadArgs* thread = StartRequestReply(zmqContext, "tcp://hostname:port", RequestReplyCallback, NULL, "logCategory");

	StopRequestReply(thread);

view raw

Using0MQRequestReply.c

hosted with ❤ by GitHub

Forwarding

	ForwardZeroMQDataThreadArgs *forwardThread = StartForward(context, "tcp://forwardTransport", "logCategory", 2, "ipc://someSubTransport", "tcp://anotherSubTransport");

	StopForward(forwardThread);

view raw

Using0MQForward.c

hosted with ❤ by GitHub

Posted in C, Messaging, ZeroMQ