remove crazy synchronisation

rade · rade · commit d27d9a70d55d · 2011-01-17T20:21:19.000Z
diff --git a/test/src/com/rabbitmq/client/test/functional/Confirm.java b/test/src/com/rabbitmq/client/test/functional/Confirm.java
@@ -49,7 +49,7 @@ public class Confirm extends BrokerTestCase
 {
     final static int NUM_MESSAGES = 1000;
     private static final String TTL_ARG = "x-message-ttl";
-    private volatile SortedSet<Long> ackSet;
+    private SortedSet<Long> ackSet;
 
     @Override
     protected void setUp() throws IOException {
@@ -276,7 +276,7 @@ private void gotAckForMultiple(long msgSeqNo) {
             gotAckFor(i);
     }
 
-    private synchronized void gotAckFor(long msgSeqNo) {
+    private void gotAckFor(long msgSeqNo) {
         if (!ackSet.contains(msgSeqNo)) {
             fail("got duplicate ack: " + msgSeqNo);
         }

Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@ public class Confirm extends BrokerTestCase`
`49`	`49`	`{`
`50`	`50`	`final static int NUM_MESSAGES = 1000;`
`51`	`51`	`private static final String TTL_ARG = "x-message-ttl";`
`52`		`- private volatile SortedSet<Long> ackSet;`
	`52`	`+ private SortedSet<Long> ackSet;`
`53`	`53`
`54`	`54`	`@Override`
`55`	`55`	`protected void setUp() throws IOException {`
`@@ -276,7 +276,7 @@ private void gotAckForMultiple(long msgSeqNo) {`
`276`	`276`	`gotAckFor(i);`
`277`	`277`	`}`
`278`	`278`
`279`		`- private synchronized void gotAckFor(long msgSeqNo) {`
	`279`	`+ private void gotAckFor(long msgSeqNo) {`
`280`	`280`	`if (!ackSet.contains(msgSeqNo)) {`
`281`	`281`	`fail("got duplicate ack: " + msgSeqNo);`
`282`	`282`	`}`