Attachment 718037 Details for Bug 929169 – Reproducer

Reproducer

test_00808098.java (text/x-java), 1.63 KB, created by Pavel Moravec on 2013-03-29 11:28:11 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2013-03-29 11:28:11 UTC

Size: 1.63 KB

patch

obsolete

>/* To the extent possible under law, Red Hat, Inc. has dedicated all copyright
> * to this software to the public domain worldwide, pursuant to the CC0 Public
> * Domain Dedication. This software is distributed without any warranty.  See
> *  <http://creativecommons.org/publicdomain/zero/1.0/>.
>*/
>
>import javax.jms.Connection;
>import javax.jms.Destination;
>import javax.jms.Message;
>import javax.jms.MessageConsumer;
>import javax.jms.Session;
>
>import org.apache.qpid.client.AMQAnyDestination;
>import org.apache.qpid.client.AMQConnection;
>import java.io.*;
>
>public class test_00808098 {
>  public test_00808098() {
>  }
>
>  private void subscribe(String destString) throws Exception {
>    Connection con = new AMQConnection("amqp://client:guest@guest/test?brokerlist='tcp://localhost:5672'");
>    con.start();
>    Session ssn = con.createSession(false,Session.AUTO_ACKNOWLEDGE);     
>    Destination dest = new AMQAnyDestination(destString);
>    MessageConsumer consumer = ssn.createConsumer(dest);
>    Message msg;
>    System.out.println("Consumer created, press enter to continue");
>    BufferedReader stdin = new BufferedReader (new InputStreamReader(System.in));
>    stdin.readLine();
>    consumer.close();
>    System.out.println("Consumer closed, press enter to continue");
>    stdin.readLine();
>    ssn.close();
>    System.out.println("Session closed, press enter to continue");
>    stdin.readLine();
>    con.close();
>    System.out.println("Connection closed, press enter to continue");
>    stdin.readLine();
>  }
>
>  public static void main(String args[]) throws Exception {
>    test_00808098 consumer = new test_00808098();
>    consumer.subscribe(args[0]);
>  }
>}

Actions: View

Attachments on bug 929169: 718037