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.
