rabbitmq

Class Message{
    private String messageResult;
    public void listenMessage()
    {
        Consumer consumer = new DefaultConsumer(channel) {
          @Override
          public void handleDelivery(String consumerTag, Envelope envelope,
                                     AMQP.BasicProperties properties, byte[] body) throws IOException {
              try {
                  String message = new String(body, "UTF-8");
              } catch (ParseException ex) {
                  Logger.getLogger(Receiver.class.getName()).log(Level.SEVERE, null, ex);
              }
          }
        };
    }
}