Author: rgodfrey
Date: Tue Jan 20 16:50:09 2015
New Revision: 1653295
URL: http://svn.apache.org/r1653295
Log:
QPID-6294 : revert unintended hanges to example file
Modified:
qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java
Modified:
qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java?rev=1653295&r1=1653294&r2=1653295&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java
(original)
+++
qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java
Tue Jan 20 16:50:09 2015
@@ -34,9 +34,6 @@ import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
-import org.apache.qpid.client.AMQConnection;
-import org.apache.qpid.configuration.ClientProperties;
-
public class Hello
{
@@ -45,38 +42,10 @@ public class Hello
{
}
- public static void main(String[] args) throws Exception
+ public static void main(String[] args)
{
- System.setProperty(ClientProperties.AMQP_VERSION, "0-91");
- System.setProperty(ClientProperties.MAX_PREFETCH_PROP_NAME, "0");
- System.setProperty(ClientProperties.DEST_SYNTAX, "BURL");
-
- Connection conn = new AMQConnection("127.0.0.1", 5672,
"admin","admin", "client", "/");
-
- conn.start();
-
- Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
- Destination destination = session.createQueue("queue");
-
- MessageConsumer consumer = session.createConsumer(destination);
- MessageProducer producer = session.createProducer(destination);
-
- for(int i = 0 ; i < 2 ; i ++)
- {
- TextMessage message = (TextMessage) consumer.receive(1000l);
- System.out.println(message == null ? "null" : message.getText());
- }
- for(int i = 0 ; i < 2 ; i ++)
- {
- TextMessage message = session.createTextMessage("Hello " + i);
- producer.send(message);
- }
-
- for(int i = 0 ; i < 2 ; i ++)
- {
- TextMessage message = (TextMessage) consumer.receive(1000l);
- System.out.println(message == null ? "null" : message.getText());
- }
+ Hello hello = new Hello();
+ hello.runTest();
}
private void runTest()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
