[Ubermq-commits] jms/src/com/ubermq/jms/client/impl Connection.java,1.28,1.29 Session.java,1.18,1.19
Brought to you by:
jimmyp
From: <ji...@us...> - 2003-02-17 18:47:10
|
Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/impl In directory sc8-pr-cvs1:/tmp/cvs-serv13103/src/com/ubermq/jms/client/impl Modified Files: Connection.java Session.java Log Message: reconnect fixes, new version number, message viewer UI tweaks. Index: Connection.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/impl/Connection.java,v retrieving revision 1.28 retrieving revision 1.29 diff -C2 -d -r1.28 -r1.29 *** Connection.java 17 Feb 2003 15:04:47 -0000 1.28 --- Connection.java 17 Feb 2003 18:46:56 -0000 1.29 *************** *** 29,33 **** public static final int UBERMQ_MAJOR_VERSION = 2; public static final int UBERMQ_MINOR_VERSION = 1; ! public static final int UBERMQ_REVISION = 3; public static final String UBERMQ_PROVIDER_NAME = "UberMQ"; public static final String UBERMQ_PROVIDER_VERSION = UBERMQ_MAJOR_VERSION + "." + --- 29,33 ---- public static final int UBERMQ_MAJOR_VERSION = 2; public static final int UBERMQ_MINOR_VERSION = 1; ! public static final int UBERMQ_REVISION = 4; public static final String UBERMQ_PROVIDER_NAME = "UberMQ"; public static final String UBERMQ_PROVIDER_VERSION = UBERMQ_MAJOR_VERSION + "." + *************** *** 180,184 **** --- 180,188 ---- theConn = theClient.connect(this, conn, clientProc); theConn.addEventListener(this); + open = true; + + // add to I/O thread + theClient.started(theConn); // notify the client proc, so that subscriptions Index: Session.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/impl/Session.java,v retrieving revision 1.18 retrieving revision 1.19 diff -C2 -d -r1.18 -r1.19 *** Session.java 30 Jan 2003 14:42:16 -0000 1.18 --- Session.java 17 Feb 2003 18:46:57 -0000 1.19 *************** *** 439,442 **** --- 439,443 ---- } } catch(RuntimeException re) { + re.printStackTrace(); if (ackMode == Session.CLIENT_ACKNOWLEDGE) { // according to JMS spec, ignore |