Package com.rabbitmq.client

Examples of com.rabbitmq.client.ReturnListener

285
286
287
288
289
290
291
292
293
294
295
        checkReturn(AMQP.NO_ROUTE);
        channel.queueDeclare(Q1, false, false, false, null);
    }

    protected ReturnListener makeReturnListener() {
        return new ReturnListener() {
            public void handleReturn(int replyCode,
                                     String replyText,
                                     String exchange,
                                     String routingKey,
                                     AMQP.BasicProperties properties,
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
        log("Leaving TestMain.run().");
    }

    private void setChannelReturnListener() {
        log("Setting return listener..");
        _ch1.addReturnListener(new ReturnListener() {
            public void handleReturn(int replyCode, String replyText, String exchange, String routingKey, AMQP.BasicProperties properties, byte[] body)
                    throws IOException {
                Method method = new AMQP.Basic.Return.Builder()
                                        .replyCode(replyCode)
                                        .replyText(replyText)
View Full Code Here
291
292
293
294
295
296
297
298
299
300
301
        throws IOException, InterruptedException {

        boolean mandatory = true;
        boolean immdediate = true;
        final CountDownLatch latch = new CountDownLatch(params.messageCount);
        channel.addReturnListener(new ReturnListener() {
                public void handleReturn(int replyCode, String replyText,
                                         String exchange, String routingKey,
                                         AMQP.BasicProperties properties, byte[] body) throws IOException {
                    latch.countDown();
                }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        return expected;
    }

    @Override protected void setUp() throws IOException {
        super.setUp();
        channel.addReturnListener(new ReturnListener() {
                public void handleReturn(int replyCode,
                                         String replyText,
                                         String exchange,
                                         String routingKey,
                                         AMQP.BasicProperties properties,
View Full Code Here
281
282
283
284
285
286
287
288
289
290
291
        log("Leaving TestMain.run().");
    }

    private void setChannelReturnListener() {
        log("Setting return listener..");
        _ch1.addReturnListener(new ReturnListener() {
            public void handleReturn(int replyCode, String replyText, String exchange, String routingKey, AMQP.BasicProperties properties, byte[] body)
                    throws IOException {
                Method method = new AMQP.Basic.Return.Builder()
                                        .replyCode(replyCode)
                                        .replyText(replyText)
View Full Code Here
291
292
293
294
295
296
297
298
299
300
301
        throws IOException, InterruptedException {

        boolean mandatory = true;
        boolean immdediate = true;
        final CountDownLatch latch = new CountDownLatch(params.messageCount);
        channel.addReturnListener(new ReturnListener() {
                public void handleReturn(int replyCode, String replyText,
                                         String exchange, String routingKey,
                                         AMQP.BasicProperties properties, byte[] body) throws IOException {
                    latch.countDown();
                }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
        return expected;
    }

    @Override protected void setUp() throws IOException {
        super.setUp();
        channel.addReturnListener(new ReturnListener() {
                public void handleReturn(int replyCode,
                                         String replyText,
                                         String exchange,
                                         String routingKey,
                                         AMQP.BasicProperties properties,
View Full Code Here
TOP

Related Classes of com.rabbitmq.client.ReturnListener

  • com.rabbitmq.client.test.functional.AlternateExchange
  • com.rabbitmq.client.test.functional.Routing
  • com.rabbitmq.client.test.performance.ScalabilityTest
  • com.rabbitmq.examples.TestMain
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.