Skip to main content

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
Re: [paho-dev] asynchronous MQTT protocol parser

Just curious whether you looked at the async client API that IBM contributed, which is in the develop branch of Eclipse Git at the moment.

I believe that there is also a bug open around moving to NIO at some stage but I may not be remembering correctly.

Is the idea of posting this here that you are looking to contribute your implementation in the future?

On Mon, Jul 8, 2013 at 11:05 AM, Julien Vermillard <jvermillar@xxxxxxxxxxxxxxxxxx> wrote:
I wrote a little MQTT protocol codec (decoder/encoder) whih convert ByteBuffer into high level MQTT protocol message and vice-versa).

The idea is to be able to handle a very large number of simultaneous connections and not blocking a thread while receiving partial chunk of MQTT messages.

This is not possible today with the current Java Paho code which parse the byte stream in a blocking way (one connection, one native thread needed).

It can be used with java NIO (or any NIO based framework) for implementing a server (I have a very basic one running and built with Apache MINA).

I plan to add the client message for being able to build asynchronous client able to spawn large number of connections (mainly for performance testing servers).

Anyway you should see it as a MQTT implemnter toolbox and not a client or server/broker implementation.

paho-dev mailing list

Andy Piper | Farnborough, Hampshire (UK)
blog:   |   skype: andypiperuk
twitter: @andypiper  |  images:

Back to the top