diff options
Diffstat (limited to 'java/client/example/src')
8 files changed, 8 insertions, 8 deletions
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DeclareQueue.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DeclareQueue.java index aa99112f32..38073cb7f2 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DeclareQueue.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DeclareQueue.java @@ -36,7 +36,7 @@ public class DeclareQueue { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DirectProducer.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DirectProducer.java index 1e571eeede..2234eb22da 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DirectProducer.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/DirectProducer.java @@ -38,7 +38,7 @@ public class DirectProducer { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/Listener.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/Listener.java index 370573c3eb..93bb097268 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/Listener.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/direct/Listener.java @@ -64,7 +64,7 @@ public class Listener implements SessionListener { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/DeclareQueue.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/DeclareQueue.java index 079be003b1..9c3ec2fb3b 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/DeclareQueue.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/DeclareQueue.java @@ -36,7 +36,7 @@ public class DeclareQueue { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/FannoutProducer.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/FannoutProducer.java index 257bcdbfb1..39d34713c6 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/FannoutProducer.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/FannoutProducer.java @@ -38,7 +38,7 @@ public class FannoutProducer { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/Listener.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/Listener.java index dead5569eb..4c72ce75a5 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/Listener.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/fanout/Listener.java @@ -64,7 +64,7 @@ public class Listener implements SessionListener { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java index 2ed5b2d719..5e6d3c6f69 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java @@ -78,7 +78,7 @@ public class TopicListener implements SessionListener { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicPublisher.java b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicPublisher.java index 20264d3791..facf08eeca 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicPublisher.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicPublisher.java @@ -57,7 +57,7 @@ public class TopicPublisher { // Create connection Connection con = new Connection(); - con.connect("localhost", 5672, "test", "guest", "guest"); + con.connect("localhost", 5672, "test", "guest", "guest",false); // Create session Session session = con.createSession(0); |