I accidently commited some modifications done for a quick test, I reversed those changes

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@616545 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 1 insertions, 19 deletions

diff --git a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java
index 1e1390941f..b5f8dfda9b 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java
@@ -34,12 +34,6 @@ import javax.jms.TextMessage;
 import javax.naming.Context;
 import javax.naming.InitialContext;
 
-import org.apache.qpid.client.AMQDestination;
-import org.apache.qpid.client.AMQQueue;
-import org.apache.qpid.client.AMQSession_0_10;
-import org.apache.qpidity.nclient.Client;
-import org.apache.qpidity.transport.Option;
-
 /**
  * Message producer example, sends message to a queue.
  */
@@ -81,8 +75,7 @@ public class Producer
             Context ctx = new InitialContext(properties);
 
             // look up destination
-            //Destination destination = (Destination)ctx.lookup("directQueue");
-            Destination destination = new AMQQueue("amq.fancy","myQeueu");
+            Destination destination = (Destination)ctx.lookup("directQueue");
 
             // Lookup the connection factory
             ConnectionFactory conFac = (ConnectionFactory)ctx.lookup("qpidConnectionfactory");
@@ -109,17 +102,6 @@ public class Producer
             System.out.println(CLASS + ": Creating a Message Producer");
             MessageProducer messageProducer = session.createProducer(destination);
 
-            try{
-                org.apache.qpidity.nclient.Connection con = Client.createConnection();
-                con.connect("qpid:password=pass;username=name@tcp:localhost:5672");
-                org.apache.qpidity.nclient.Session ses = con.createSession(1000000);
-                ses.exchangeDelete("amq.direct", Option.NO_OPTION);
-            }
-            catch(Exception e)
-            {
-                e.printStackTrace();
-            }
-
             // Create a Message
             TextMessage message;
             System.out.println(CLASS + ": Creating a TestMessage to send to the destination");