minor tweak to ConfirmDontLoseMessages

Alexandru Scvortov · Alexandru Scvortov · commit 7e6d92052195 · 2011-01-12T10:57:58.000Z
diff --git a/test/src/com/rabbitmq/examples/ConfirmDontLoseMessages.java b/test/src/com/rabbitmq/examples/ConfirmDontLoseMessages.java
@@ -73,7 +73,6 @@ public void run() {
                 Connection conn = connectionFactory.newConnection();
                 Channel ch = conn.createChannel();
                 ch.queueDeclare(QUEUE_NAME, true, false, true, null);
-                ch.confirmSelect();
                 ch.setAckListener(new AckListener() {
                         public void handleAck(long seqNo,
                                               boolean multiple) {
@@ -85,6 +84,7 @@ public void handleAck(long seqNo,
                             }
                         }
                     });
+                ch.confirmSelect();
 
                 // Publish
                 for (long i = 0; i < MSG_COUNT; ++i) {

Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,6 @@ public void run() {`
`73`	`73`	`Connection conn = connectionFactory.newConnection();`
`74`	`74`	`Channel ch = conn.createChannel();`
`75`	`75`	`ch.queueDeclare(QUEUE_NAME, true, false, true, null);`
`76`		`- ch.confirmSelect();`
`77`	`76`	`ch.setAckListener(new AckListener() {`
`78`	`77`	`public void handleAck(long seqNo,`
`79`	`78`	`boolean multiple) {`
`@@ -85,6 +84,7 @@ public void handleAck(long seqNo,`
`85`	`84`	`}`
`86`	`85`	`}`
`87`	`86`	`});`
	`87`	`+ ch.confirmSelect();`
`88`	`88`
`89`	`89`	`// Publish`
`90`	`90`	`for (long i = 0; i < MSG_COUNT; ++i) {`