1回答
我的所有服务和类都用Component或Service注解进行了修饰，但我仍然收到以下异常：应用程序设置增加了: cloud: stream: kafka: binder: brokers: localhost zk-nodes
浏览 0提问于2017-11-30得票数 1
我正在尝试使用spring绑定来运行发布者和订阅者。 确保在rabbit mq上本地创建目标(Exchange)。rabbitmq: cloud: bindings:groupId>
浏览 49提问于2019-05-26得票数 1
看来，通道名称正在与应用程序包装器的toString()结果连接起来，以创建实际的通道名称。
org.springframework.web.context.support.Anno
浏览 1提问于2019-03-28得票数 1
回答已采纳
1回答
在我看来，这似乎是最简单的春季集成示例。我正试着向学习。但是当我运行它的时候，我得到了一个例外：
线程“主”org.springframework.messaging.MessageDeliveryException:调度程序中的异常没有订阅通道‘application.inbox. in’的订阅者。嵌套的异常是org.springframework.integration.Me
浏览 4提问于2016-04-03得票数 2
回答已采纳
1回答
Dispatcher没有订阅通道‘DataHubWebApplicationContext.DEBMAS-DEBI’的订阅者。嵌套的例外是org.springframework.integration.MessageDispatchingException:调度程序没有订阅者。rawFragmentDataInputChannel" ref="sapcustom
浏览 3提问于2017-05-09得票数 0
回答已采纳
当尝试运行下面提到的spring集成流程时，我得到一个错误:-
org.springframework.jms.listener.DefaultMessageListenerContainer [consumeTradeJSONChannelAdapter.container
浏览 1提问于2018-09-01得票数 0
我正在尝试使用出站网关从sftp服务器下载文件，我的配置如下：@EnableIntegrationpublic classgatewayOption.mget("/sftp/server/path");}
我得到这个exception:org.springframework.messaging.MessageDeliveryException:调度程序没有通道‘a
浏览 0提问于2017-10-17得票数 0
2回答
在蔚蓝门户中创建调度器作业集时，我无法找到订阅错误。我对资源组具有基于所有者角色的访问控制(RBAC)，但是.I能够创建存储帐户，但是当我尝试创建调度器时，azure抛出无法找到带有Microsoft.Scheduler命名空间的订阅错误。如果我发布作为订阅调度程序的所有者自动创建的网页作业，我也可以手动创建。
资源组所有者访问是否足以在azu
浏览 3提问于2016-01-18得票数 1
1回答
没有订阅者
、、、、
没有订阅者错误。在成功启动spring引导容器之后，我们需要将很少的通知消息放在Kafka主题上，并且我们的一些微服务具有相同的功能，为此，我们编写了一个包含输出通道定义和分派实用程序的公共jar。org.springframework.context.ApplicationContextException:未能启动bean 'outputBindingLifecycle'；嵌套异常是org.springframe
浏览 3提问于2017-03-29得票数 1
我编写了一个使用spring-cloud-starter-stream-rabbit的测试类，当我只运行receiver，并从rabbitmq发送一条消息时，它可以工作；但当我运行测试发送器类时，它发生了一个错误我的步骤： 首先，运行测试；其次，运行JUnit SpringbootApplication utf8 -boot-starter-parent 2.1.3发布JDK8 rabbitmq spring如下所示的堆栈跟踪： org.springframework.messaging.MessageDeliveryException:
浏览 11提问于2019-04-21得票数 1
回答已采纳
我正在尝试这个用例:轮询队列中的消息->转换消息->使用转换后的消息调用方法。以下是我的代码 destination-name="test"="vorActivator" class="com.order.jmspublisher.VORServiceActivator"/>
</
浏览 24提问于2017-08-27得票数 1
回答已采纳
1回答
在我的春季云流应用程序中，我有一个简单的Kafka生产者。当我的spring应用程序启动时，我有一个@PostConstruct方法，它执行一些协调，并尝试将事件发送给Kafka生产者。没有为通道‘orderbook-service-1 . orderbook’订阅。嵌套的例外是org.springframework.integration.MessageDispatchingException:<
浏览 1提问于2019-11-27得票数 1
我想用PublishSubscribeAmqpChannel通过rabbitmq向其他系统发送消息，我的系统不需要消费这个消息。当我这样做的时候，我总是收到警告"Dispatcher has no subscribers for amqp-channel‘
浏览 56提问于2021-01-30得票数 1
回答已采纳
endpointMap.put("/ws/test", testInboundGateWay ); }
即使服务激活器订阅了org.springframework.web.context.WebApplicationContext:/MyProject -在网关sendAndReceive中发生故障: Dispatcher没有订阅通道o.s.i.w.SimpleWebServiceInboundGatew
浏览 0提问于2016-07-15得票数 2
回答已采纳
我使用spring cloud stream版本2.1.0.RELEASE将消息(在本例中是发送到Kafka)发送到基于接收到的输入动态定义的通道。问题是，只有每隔一条消息才会在正确的通道中结束，而另一半消息会在默认的通道中结束。 我使用this示例作为起点。我将想要发送到的通道放在特定的消息头中，然后使用HeaderValueRouter检查相同的报头值，以确定输出到哪个通道。我
浏览 26提问于2019-01-19得票数 1
我正在尝试在应用程序启动时使用spring cloud stream向rabbitmq发送消息。使用下面的示例代码。public interface Barista { SubscribableChannel orders();支持绑定的SpringBoot应用程序 // System.out.println(message);}
上面的代
浏览 0提问于2018-06-14得票数 1
1回答
使用RabbitMQ，我有一个服务，它使用队列的消息，然后根据这些消息下载页面，并在另一个队列上发布另一条消息，该队列最终被消耗并存储在数据库中。但我遇到了一个特殊的来源，它是缓慢的，并导致一切崩溃。private void ReceivedHandler(object model, BasicDeliverEventArgs ea所以
浏览 3提问于2016-06-15得票数 1
1回答
我在中发布了一个关于如何处理从聚合器中释放消息组的逻辑的问题，并得到了一些有用的响应，但我无法让逻辑按我的意愿工作，所以我将后退一步，问一个更基本的一般性问题，试图理解聚合器是如何工作的。以下是我正在努力实现的目标。我想将这些消息发送到我的spring集成流，其中这些消息基本上是通过聚合器路由的。setCorrelationId("1").build());
in.send(MessageBuilder.withP
浏览 0提问于2014-04-30得票数 0
回答已采纳
1回答
根据本期#1623、Binder Implementation和Spring Cloud Stream Refrence中的对话 我想注入Sink对象，并为输入通道订阅一个MessageHandler，但在调用带注释的Sink时，该对象似乎没有正确创建。-02 16:51:05.915 INFO 21 --- [ main] o.s.c.s.m.DirectWithAttributesChannel : Channel 'unknown.channel.nam
浏览 73提问于2019-03-02得票数 1
2回答
我正在尝试使用NServiceBus实现发布订阅通道。根据“企业集成模式”()一书，普利什订阅频道被描述为：
发布-订阅通道的工作方式如下:它有一个输入通道，分成多个输出通道，每个订阅者一个。当事件被发布到通道中时，发布订阅通道将消息的副本传递给每个输出通道。通道的每个输出端只有一个
浏览 0提问于2016-01-20得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
