Commit 3f08faea authored by afreyssin's avatar afreyssin

Minor changes.

parent a4410fb6
...@@ -79,6 +79,9 @@ public class BridgeRestTest6 extends TestCase implements MessageListener { ...@@ -79,6 +79,9 @@ public class BridgeRestTest6 extends TestCase implements MessageListener {
AdminModule.executeXMLAdmin("joramAdmin.xml"); AdminModule.executeXMLAdmin("joramAdmin.xml");
else else
admin(); admin();
System.out.println("admin config ok");
Thread.sleep(1000);
test(); test();
} catch (Throwable exc) { } catch (Throwable exc) {
...@@ -118,9 +121,7 @@ public class BridgeRestTest6 extends TestCase implements MessageListener { ...@@ -118,9 +121,7 @@ public class BridgeRestTest6 extends TestCase implements MessageListener {
Queue distQueue = new RestDistributionQueue() Queue distQueue = new RestDistributionQueue()
.setHost("localhost") .setHost("localhost")
.setPort(8989) .setPort(8989)
.setPeriod(1000)
.setIdleTimeout(10) .setIdleTimeout(10)
.setBatch(true)
.create(0, "distQueue", "foreignQueue"); .create(0, "distQueue", "foreignQueue");
distQueue.setFreeWriting(); distQueue.setFreeWriting();
System.out.println("joram distribution queue = " + distQueue); System.out.println("joram distribution queue = " + distQueue);
...@@ -140,9 +141,6 @@ public class BridgeRestTest6 extends TestCase implements MessageListener { ...@@ -140,9 +141,6 @@ public class BridgeRestTest6 extends TestCase implements MessageListener {
jndiCtx.close(); jndiCtx.close();
AdminModule.disconnect(); AdminModule.disconnect();
System.out.println("admin config ok");
Thread.sleep(1000);
} }
// public void test() throws Exception { // public void test() throws Exception {
...@@ -241,7 +239,7 @@ public class BridgeRestTest6 extends TestCase implements MessageListener { ...@@ -241,7 +239,7 @@ public class BridgeRestTest6 extends TestCase implements MessageListener {
String current = "Message number #" + nbmsg; String current = "Message number #" + nbmsg;
String txt = ((TextMessage) msg).getText(); String txt = ((TextMessage) msg).getText();
System.out.println(txt); // System.out.println(txt);
if (! current.equals(txt)) { if (! current.equals(txt)) {
// Verify if it is a duplicate due to the server's failure. // Verify if it is a duplicate due to the server's failure.
if ((previous == null) || (! previous.equals(txt))) { if ((previous == null) || (! previous.equals(txt))) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment