I'm trying to implement messages broadcast within 3 nodes conventional
masterbroker cluster using JMS.
It seems to work OK without much load and under high load at the begining
but after a while (~200000 messages from each node) performance degrades
dramatically and nodes don't receive all messages (e.g. one has 150000
another - 100000 or so)
Connection factory attribute useSharedSubscriptionInClusteredContainer is set
to false.
Producer gets started like following
cf = (ConnectionFactory) ctx.lookup("CF");
bus = (Destination) ctx.lookup("D1");
conn = cf.createConnection();
sess = conn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
prod = sess.createProducer(bus);
prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
prod.setDisableMessageID(true);
prod.setDisableMessageTimestamp(true);
msg = sess.createObjectMessage();
conn.start();
Consumer - like following
bus = (Destination)ctx.lookup("D1");
conn = cf.createConnection();
sess = conn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
cons = sess.createConsumer(bus);
conn.start();
Messages get received using cons.receive(); What am doing wrong? Many thanks
in advance.
--
[Message sent by forum member 'alex2001']
View Post: http://forums.java.net/node/810856