Package org.springframework.amqp.rabbit.listener

Examples of org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.start()

90
91
92
93
94
95
96
97
98
99
100
        // empty out queue
        while (template.receive("testQueue") != null) {
            // do
        }

        container.start();

        // template.setChannelTransacted(true);

        // send all the messages
        long start = new Date().getTime();
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
    MessageListenerAdapter adapter = new MessageListenerAdapter();
    adapter.setDelegate(new PojoHandler());
    container.setMessageListener(adapter);
    container.afterPropertiesSet();
    container.start();

    while (true) {
      Thread.sleep(10000);
    }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
      SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
      container.setConnectionFactory(connectionFactory);
      //container.setTaskExecutor(taskExecutor);
      container.setQueueNames(qName);
      container.setMessageListener(new AmqpMessageHandler(sessionId));
      container.start();
     
      sessions.put(sessionId, container);
      msg.reply(new JsonObject());
    }
  }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(
        cf);
    container.setMessageListener(template);
    container.setQueueNames(queue.getName());
    container.start();

    containers.add(container);

    log.debug("Created RabbitMqTemplate receiving messages in queue: {}",
        queue.getName());
View Full Code Here
225
226
227
228
229
230
231
232
233
234
235
          }
        }, "onMessage");

    container.setMessageListener(adapter);
    container.setQueueNames(queue);
    container.start();

    containers.add(container);

    log.debug("Registered receiver '" + receiver.getClass().getName()
        + "' for queue '" + queue);
View Full Code Here
256
257
258
259
260
261
262
263
264
265
266
          }
        }, "onMessage");

    container.setMessageListener(adapter);
    container.setQueueNames(queue);
    container.start();

    containers.add(container);

    log.debug("Registered receiver with response '"
        + receiver.getClass().getName() + "' for queue '" + queue);
View Full Code Here
53
54
55
56
57
58
59
60
61
                listenerContainer.shutdown();
            }
        });

        // start up the listener. this will block until JVM is killed.
        listenerContainer.start();
        System.out.println("BigOperationWorker started");
    }
}
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
                t.printStackTrace();
            }
        });

        try {
            container.start();

            amqpTemplate.convertAndSend(rabbitQueue.getName(), new BigOperation("foo"));
            assertTrue(fooLatch.await(5, TimeUnit.SECONDS));
            assertEquals(receievedMessageHolder.get(0).getName(), "foo");
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
            SimpleMessageListenerContainer newContainer = createContainer(amqpConfig);
            newContainer.setQueueNames(queueName);
            newContainer.setMessageListener(new ClusterMessageListener(cluster, messageConverter));
            containerPerQueue.put(queueName, newContainer);
            if (started) {
                newContainer.start();
            }
        }
    }

    @Override
View Full Code Here
346
347
348
349
350
351
352
353
354
355
356
          consume.setDelegate((Closure) param);
        }
      }
      listenerContainer.setQueues(currentQueue);
      listenerContainer.afterPropertiesSet();
      listenerContainer.start();
      listenerContainers.add(listenerContainer);

      return super.invokeMethod(methodName, consume);
    } else if (PUBLISH.equals(methodName)) {
      Publish publish = new Publish();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.