User: pkendall
Date: 01/05/13 01:51:32
Modified: src/main/org/jbossmq SpyConnection.java
Log:
Synchronize update of the lastMessageId.
Revision Changes Path
1.6 +4 -2 jbossmq/src/main/org/jbossmq/SpyConnection.java
Index: SpyConnection.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/SpyConnection.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- SpyConnection.java 2001/03/02 01:12:40 1.5
+++ SpyConnection.java 2001/05/13 08:51:31 1.6
@@ -38,7 +38,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.5 $
+ * @version $Revision: 1.6 $
*/
public class SpyConnection implements java.io.Serializable, javax.jms.Connection {
//////////////////////////////////////////////////////////////
@@ -287,7 +287,9 @@
if (distributedConnection == null)
createReceiver();
- return clientID + "-" + (lastMessageID++);
+ synchronized(clientID) {
+ return clientID + "-" + (lastMessageID++);
+ }
}
//notify his sessions that he has changed his stopped mode
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development