作用
实现消息监听
发出消息时，会包含一个String类型的payload和含有contentType的Header信息。@StreamListener能够根据发送消息时的头信息contentType自动完成转换处理
用法
1、
/*********************************User对象处理实现******************************/
@StreamListener(MySink.USER_CHANNEL)
public void userReceive(@Payload User user, @Headers Map headers) {
LOGGER.info(headers.get("contentType").toString());
LOGGER.info("Received from {} channel username: {}", MySink.USER_CHANNEL, user.getUsername());
}
@StreamListener(value = MySink.USER_CHANNEL)
public void userReceive(@Payload User user, @Headers Map headers, @Header(name = "name") Object name) {
LOGGER.info(headers.get("contentType").toString());
LOGGER.info("name : {}", name.toString());
LOGGER.info("Received from {} channel username: {}", MySink.USER_CHANNEL, user.getUsername());
}
