- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试使用事件过滤器来减少应用程序使用的主题数量,使用新版本的 spring 云流 (Chelsea.RC1) 中可用的新功能。正在创建具有正确 header 的消息,但是,检查队列中消息的内容,消息不包含 header ,仅包含带有有效负载的正文。
public void sendEnroll(EnrollCommand data) {
//MessageChannel
outputEnroll.send(MessageBuilder
.withPayload(data)
.setHeader("brand", "MASTERCARD")
.setHeader("operation", Operation.ENROLL).build());
}
消费者
@Service
@EnableBinding(Channel.class)
public class EnrollConsumer {
@Autowired
private EnrollService service;
@StreamListener(target = Channel.INPUT_ENROLL, condition = "headers['brand']=='MASTERCARD'")
public void enrollConsumer(@Payload String command){
System.out.println(command);
//service.enrollment(command);
}
}
在消费者服务中,它给出如下警告:
WARN -kafka-listener-1 o.s.c.s.b.DispatchingStreamListenerMessageHandler:62 - Cannot find a @StreamListener matching for message with id: 7baae934-7484-a7fd-91b0-ba906558bb13
最佳答案
您必须映射您的自定义 header :
spring.cloud.stream.kafka.binder.headers = brand,operation
该信息存在于 documentation 中.
关于spring-cloud - 使用新版本 Chelsea.RC1 的 "condition paramter header"@StreamListener 时出错,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42910265/
有时我们需要创建只有一个参数的简单方法。例如: private boolean isMockedPlayer(Player player) { return player == Player.
我正在尝试使用 Google Cloud Endpoints 构建一个 API。 由于 Cloud Endpoints 不提供除 Google 自己的 OAuth 之外的身份验证,所以我尝试构建自己的
我正在使用 socket io 构建聊天应用。 当“用户 x”从聊天中断开连接时,我想打印到控制台日志:“再见用户 x”。 为此,我需要将用户名作为参数传递给断开连接事件。 问题是我不知道如何将数据传
如何在 Javascript 回调函数中获取用户状态?就像我有一个 Javascript 函数,如下所示进行异步调用。现在在回调函数中我需要访问用户状态。我怎样才能做到这一点?在 Silverligh
如果我尝试从 MySQL 数据库中选择数据库,我会收到一条错误消息:该值不能为 NULL。参数:item(德语为:Der Wert darf nicht NULL sein。参数:item)因此,这意
在 mySQL SELECT 查询中,我想根据 WHERE 子句中的 PDO 绑定(bind)搜索参数条件选择客户端表的行。类似于 WHERE client = :searchStr 有2种情况:A)
我正在尝试使用事件过滤器来减少应用程序使用的主题数量,使用新版本的 spring 云流 (Chelsea.RC1) 中可用的新功能。正在创建具有正确 header 的消息,但是,检查队列中消息的内容,
我是一名优秀的程序员,十分优秀!