Attachment 876892 Details for Bug 1078927 – Reproducer

Reproducer

test_01003483.java (text/x-java), 2.49 KB, created by Pavel Moravec on 2014-03-20 14:46:42 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2014-03-20 14:46:42 UTC

Size: 2.49 KB

patch

obsolete

>import org.slf4j.Logger;
>import org.slf4j.LoggerFactory;
>
>import javax.jms.*;
>
>import org.apache.qpid.client.*;
>
>
>public class test_01003483 {
>
>    final MessageListener messageListener = new MessageListener()
>    {
>        @Override
>        public void onMessage(final Message message)
>        {
>            if (++messageProcessed == msgBeforeClose) {
>                try {
>                    unsubscribe();
>		    Thread.sleep(10);
>                    subscribe();
>                } catch (Exception e) {
>                    logger.error("Error closing connection: [{" + connection + "}]", e);
>                }
>             } else {
>                 logger.info("Message Received: [{}]", message);
>             }
>        }
>    };
>
>
>
>    private final Logger logger = LoggerFactory.getLogger(getClass());
>
>    private volatile int messageProcessed;
>    private static int msgBeforeClose;
>    private volatile Connection connection;
>    private Session session;
>    private Destination dest;
>    private MessageConsumer receiver;
>    public static void main(String[] args) {
>        if (args.length < 1) {
>            System.out.println("Expecting number of blue messages sent and received.");
>            return;
>        }
>        msgBeforeClose = Integer.parseInt(args[0]);
>        test_01003483 test = new test_01003483();
>    }
>
>    public test_01003483() {
>        try {     
>            messageProcessed = 0;
>            subscribe();
>            Thread.sleep(10000000);
>            receiver.close();
>        }
>        catch(Exception e)
>        {
>            System.out.println("Caught exception:");
>            e.printStackTrace();
>        }
>    }
>
>    public void subscribe() throws Exception {
>        try {
>            connection = new AMQConnection("amqp://anonymous:anonymous@clientid/test?brokerlist='tcp://localhost:5672'");
>            session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
>            dest = new AMQAnyDestination("testQueue; {create:always}");
>            receiver = session.createConsumer(dest);
>            receiver.setMessageListener(messageListener);
>
>            connection.start();
>        } catch (RuntimeException e) {
>            throw e;
>        } catch (Exception e) {
>            throw new RuntimeException(e);
>        }
>    }
>
>    public void unsubscribe() {
>        try {
>            messageProcessed = 0;
>            connection.close();
>        } catch (RuntimeException e) {
>            throw e;
>        } catch (Exception e) {
>            throw new RuntimeException(e);
>        }
>    }
>
>}

Actions: View

Attachments on bug 1078927: 876892