Как читать заголовки в RabbitMQ на Java?

Question

У меня есть некоторые свойства, которые я хотел бы прочитать из ранее заданных заголовков сообщений. Я сделал это:

Delivery delivery = consumer.nextDelivery(); 
Map<String, Object> headers = delivery.getProperties().getHeaders(); 

Проблема в том, что у заголовков странные типы - например, LongString. Есть ли вспомогательный класс, который позволит мне легко конвертировать заголовки в что-нибудь более полезное?

Answer 1

Вы должны поместить заголовки в своем сообщении:

MessageProperties props = MessagePropertiesBuilder.newInstance().setContentType(MessageProperties.CONTENT_TYPE_JSON).build(); 
props.setHeader("headerKey1", "headerValue1"); 

Message msg = new Message("{'body':'value1','body2':value2}".getBytes(), props);   

rabbitTemplate.send("exchange.direct.one", new String(), msg); 

Для чтения заголовков входящего сообщения из очереди Rabbit:

import org.springframework.amqp.core.Message; 
    import org.springframework.amqp.core.MessageListener; 

    public class MessagesHandler implements MessageListener { 

     public void onMessage(Message message) { 
      Map<String, Object> headers = message.getMessageProperties().getHeaders(); 
      for (Map.Entry<String, Object> header : headers.entrySet()) 
      { 
       System.out.println(header.getKey() + " : " + header.getValue()); 
      } 
     } 
    } 

Answer 2

Вот как я был в состоянии сделать это, я литье в LongString, а затем преобразовать в строку:

protected String extractCorrelationIdFromHeaders(AMQP.BasicProperties properties) throws UnsupportedEncodingException { 

    String decodedCorrelationId=null; 

    if(properties.getHeaders() != null) { 

     try { 
      Object rawCorrelationId = properties.getHeaders().get(CORRELATION_ID_KEY); 

      if(rawCorrelationId==null){ 
       log.info("no correlationId provided in headers"); 
       return null; 
      } 

      byte[] correlationIdAsByteArray = ((LongString) rawCorrelationId).getBytes(); 

      decodedCorrelationId = new String(correlationIdAsByteArray, "UTF-8"); 
     } 
     catch(UnsupportedEncodingException e){ 
      log.warn("extracted correlationId, but unable to decode it",e); 
     } 
    } 

    return decodedCorrelationId; 
} 

Как ни странно, я чувствую, что это не очень хорошо документированы там. Надеюсь это поможет !