Nullpointer exception after processing 17 incoming messages

[anukoolrege]

I have a C# producer producing messages. The messages are streamed to a Mule ZeroMQ consumer.

Ran into the error below right after processing of 17th messages (always).

Caused by: java.lang.NullPointerException
at org.mule.transport.zmq.ZMQTransport$InboundWorker.run(ZMQTransport.java:374)
at org.mule.work.WorkerContext.run(WorkerContext.java:311)
... 10 more

To get around, changed line 373 on org.mule.transport.zmq.ZMQTransportto check for workerSocket null. It worked!

if (workerSocket != null) workerSocket.close();