스프링 AMQP 헤더가 문자열로만 반환됩니다

Question

버전 2.0.0의 Java Spring을 사용하고 있습니다. AMQP의 스냅 샷. AMQP 메시지를 작성하여 보냅니다. 다른 서비스에서는 Object를받는 대신 머리글을 제외하고 올바르게 메시지를받습니다. 모든 헤더는 String 유형입니다.

게시자 코드 :

소비자 코드

Message responseMessage = MessageBuilder 
    .withBody(SerializationUtils.serialize(person)) 
    .setContentType(MessageProperties.CONTENT_TYPE_SERIALIZED_OBJECT) 
    .setHeader("STUDENT_TYPE", "New") // Not part of person object but related 
    .setHeader("PET", getPet()) // This is a pet object 
    .build(); 
rabbitTemplate.send(responseMessage); 

: 나는 위의 코드를 실행하면

Object messageBody = SerializationUtils.deserialize(amqpMessage.getBody()); 
Person person = (Person)messageBody; 
MessageProperties properties = amqpMessage.getMessageProperties(); 
String type = properties.getHeaders().get("STUDENT_TYPE").toString(); 
Pet pet = (Pet)properties.getHeaders().get("PET"); 

, 나는 오류가있는 소비자 코드의 마지막 줄에 실패는 : 문자열로 캐스팅 할 수 없습니다 착한 애. 모든 헤더가 소비자 코드에서 수신되면 String 유형 인 것을 제외하고는 메시지가 정상적으로 나타납니다.

USAGE: MessageBuilder.setHeader(String Key, Object Value); 

USAGE: Properties.getHeaders() returns Map<String,Object> 

모든 헤더에는 String/Object 유형의 키/값 쌍이 있습니다. 내가 가지고있는 주위의 작업은 또한 비 문자열/정수 값을 전달하고 싶습니다 헤더를 serialize하는 것입니다,하지만 이것은 헤더의 포인트 외의 것으로 보인다. 내가 놓친 게 있니?

Answer 1

당신은 문자열로 당신의 애완 동물을 직렬화 할 필요가, 그리고 다른 서비스를받을 때를 역 직렬화. 예 : 당신은 fasterxml Jackson을 사용하여 JSON 문자열에 직렬화합니다.

Answer 2

컴파일러에게 String은 실제로 애완 동물이라고 말하고 있습니다. 그러나 Pet은 subclass이 String이 아닙니다.

Solution1 : 이런 식으로, 당신은 확실히 Pet extends String합니다

public class Pet extends String { 
    //... 
} 

을 그리고 당신은 Pet에 String을 시전 할 수있을 것 두 가지 가능한 솔루션입니다.

Solution2 : 당신은 매개 변수로 String 소요 Pet의 생성자 구현 :

public class Pet { 
    //... 
    Public Pet(String name) { 
     //... 
    } 
    //... 
}