1、发送消息的代码:
this.source.output().send(MessageBuilder.withPayload("{'name':'zyy'}").setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON).build());
2、接受消息的代码:
@StreamListener(target = Sink.INPUT)
public void onProductMsg(@Payload Object object) {
System.out.println(object);
}
3、结果:
4、请教大家怎么去掉contentType、application/json字符串