svn commit: r616545 - /incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java

[rajith]

Author: rajith
Date: Tue Jan 29 14:30:20 2008
New Revision: 616545

URL: http://svn.apache.org/viewvc?rev=616545&view=rev
Log:
I accidently commited some modifications done for a quick test, I reversed 
those changes

Modified:
    
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java

Modified: 
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java?rev=616545&r1=616544&r2=616545&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java
 Tue Jan 29 14:30:20 2008
@@ -34,12 +34,6 @@
 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 @@
             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");
@@ -108,17 +101,6 @@
             // Create a Message 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;[EMAIL 
PROTECTED]: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;