diff options
Diffstat (limited to 'java/client/example/src')
| -rw-r--r-- | java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java | 20 |
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"); |