Subscriber internal queue implementation

Implemented an internal blocking queue for the subscriber. This will be
the connection between the subscriber's receiver callback and the socket
i/o threads. It should help in case subscriber has some heavy processing
inside the callback.
Load test tweaks

Reduced the iteration, increased the message size and added an MB per
second variable.
Merge branch 'try/using-internal-queue'
Loop test