3 Replies Latest reply on Jun 4, 2012 12:37 PM by blacar

How to receive stomp messages (without std MessageConsumer)

blacar Jun 4, 2012 11:51 AM

Hello,

I am trying to make a proof of concept usong stomp protocol with hornetq ... i've seen the examples that comes with the documentation and ive created the producer using the same idea (open a socket and sending text frames as i were using telnet) ... it seems to work, but i have not a clear idea about how to implement the consumer, since this does not comes with the example ... in the example the consumer is implemented using normal MessageConsumer class, and i am interested in using same socket approach, or Stomp specific classes that could come with hornetq.

Also i've seen references to some StompConnection, StompFrame, ... classes. And i am confused ... should i use these classes?

Are there some documentation source where to consult this topic more clear?

I am using hornetq 2.2.14.Final

Thanks!!

1. Re: How to receive stomp messages (without std MessageConsumer)

jmesnil Jun 4, 2012 11:53 AM (in response to blacar)

to implement a STOMP consumer, you just have to listen to Stomp MESSAGE frames on the socket after you client is authenticated.

StompConnection, StompFrame, etc. are HornetQ internal classes and are not meant to be used on the client side.
Actions
2. Re: How to receive stomp messages (without std MessageConsumer)

blacar Jun 4, 2012 12:14 PM (in response to jmesnil)

Hi Jeff, thanks for the answer

So i only need to get an input stream from the socket and perform read operations in the same port i used to send the message?
Actions
3. Re: How to receive stomp messages (without std MessageConsumer)

blacar Jun 4, 2012 12:37 PM (in response to jmesnil)

Ok Jeff,

You are right, of course ... i was able to capture the CONNECTED response, and i expect be able to capture all other responses.

However i wonder if there is any restriction about the size of the message ... related connection timeout, stomp specific restrictions, or something like that,

Thanks again.
Actions

Go to original post