I have a client that connects to the server with a publisher and subscriber on
the same topic. The publisher publishes 1 KB message as fast as he can. The
subscriber is setup as follows:
| subscriber =subscriberSession.createSubscriber(topic, null, true);
| subscriber.setMessageListener(new MessageListener(){
| public void onMessage(Message message) {
| messagesReceived++;
| }
| };
|
The number of messages received stays at zero BUT the number of messages on the
server waiting to be delivered steadily increases, to the point that I run out
of heap space. It would seem that it is correctly ignoring the messages on the
client but that the client or server is not acknowledging the message so the
messages stay in the queue on the server.
The messages are being sent as Non_perstistent on Jboss Messaging 1.4.0 GA with
remoting 2.2.2 GA on JBoss 4.2.1
If I set:
| subscriberSession.createSubscriber(topic, null, false);
|
I correctly receive the messages and the number of messages waiting to be
delivered on the server remains at 0.
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4093148#4093148
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4093148
_______________________________________________
jboss-user mailing list
[email protected]
https://lists.jboss.org/mailman/listinfo/jboss-user
