Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- protected LinkedBlockingQueue<Message> messages = new LinkedBlockingQueue<>();
- public void receiveMessages() {
- try {
- // channel.basicQos(pollCount);
- Message message = new Message();
- Consumer consumer = new DefaultConsumer(channel) {
- @Override
- public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
- throws IOException {
- long deliveryTag = envelope.getDeliveryTag();
- String response = new String(body, "UTF-8");
- if (response != null) {
- message.setId(NUID.nextGlobal());
- message.setPayload(response);
- message.setDeliveryTag(deliveryTag);
- messages.add(message);
- logger.info("Message received: ", message.getPayload());
- }
- }
- };
- logger.debug("**********Channel status: " + channel.isOpen());
- channel.basicConsume(queueName, false, consumer);
- } catch (Exception e) {
- logger.error("Exception while getting messages from Rabbit ", e);
- }
- }
Add Comment
Please, Sign In to add comment