[Ubermq-commits] jms/src/com/ubermq/jms/client/proc ClientProc.java,1.15,1.16
Brought to you by:
jimmyp
From: <ji...@us...> - 2002-10-21 21:11:35
|
Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/proc In directory usw-pr-cvs1:/tmp/cvs-serv3958/src/com/ubermq/jms/client/proc Modified Files: ClientProc.java Log Message: documentation, bug fixes, new administrative interface (only marginally functional), better reconnect logic. Index: ClientProc.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/proc/ClientProc.java,v retrieving revision 1.15 retrieving revision 1.16 diff -C2 -d -r1.15 -r1.16 *** ClientProc.java 18 Oct 2002 16:59:27 -0000 1.15 --- ClientProc.java 21 Oct 2002 21:11:02 -0000 1.16 *************** *** 124,128 **** SourceSpec ss = new MessageIdSourceSpec(ad.getAckMessageId()); ! Iterator acks = ackRouter.getRoutes(ss); if (!acks.hasNext()) return; --- 124,128 ---- SourceSpec ss = new MessageIdSourceSpec(ad.getAckMessageId()); ! Iterator acks = ackRouter.getRoutes(ss).iterator(); if (!acks.hasNext()) return; *************** *** 136,140 **** private void msg(IMessageDatagram md) { ! for(Iterator acks = subRouter.getRoutes(md.getTopicName());acks.hasNext();) { EndpointDestNode edn = ((EndpointDestNode)acks.next()); --- 136,140 ---- private void msg(IMessageDatagram md) { ! for(Iterator acks = subRouter.getRoutes(md.getTopicName()).iterator();acks.hasNext();) { EndpointDestNode edn = ((EndpointDestNode)acks.next()); *************** *** 169,173 **** { boolean alreadyRegistered = ! (subRouter.getRoutes(ss).hasNext()); // register with our internal router --- 169,173 ---- { boolean alreadyRegistered = ! (subRouter.getRoutes(ss).size() > 0); // register with our internal router *************** *** 207,211 **** // tell server that i no longer care if there are no more in the // internal router. ! if (!(subRouter.getRoutes(ss).hasNext()) && fSendControlDgrams) { controlSequence(controlFactory.unsubscribe(spec), controlHandler); --- 207,211 ---- // tell server that i no longer care if there are no more in the // internal router. ! if (!(subRouter.getRoutes(ss).size() > 0) && fSendControlDgrams) { controlSequence(controlFactory.unsubscribe(spec), controlHandler); |