我使用了publishSubscribeChannel并添加了一个taskExecutor来实现异步。 下面是代码。IntegrationFlow mainFlow(){ ..
.publishSubscribeChannel现在我想实现一个处理testFlow异常的errorChannel。那么最好的方法是什么呢
浏览 17提问于2019-09-02得票数 0
回答已采纳
我使用和JTA支持，通过Atomikos和JMS绑定到不同的Webshpere，包括入站和出站。流动情况如下：
异常类型路由器将未处理的错误路由到自定义重新抛出服务我的问题是，即使消息沿errorChannel下行(在已处理的异常情况下和错误队列上)，我也希望事务被提交。据我所知，只有当异常被重新抛出时<
浏览 0提问于2016-10-28得票数 1
回答已采纳
3回答
在入站网关接收到字符串消息后，我使用发布-订阅通道将其并行发送到记录器以记录消息，并发送到转换器以转换消息。我希望这两个活动并行进行。我的问题很简单- spring集成中的发布订阅通道是否并行地向其子用户发送消息？ </int:gateway>
<int:publish-su
浏览 1提问于2013-09-03得票数 3
我是spring集成的新手。我正在为我们的项目评估Spring Integration。我遇到了一个关于如何处理异常的问题。
我正在使用publishSubscribeChannel来处理消息。我不知道这是不是一个正确的方法。当异常在publishSubscribeChannel中抛出时，我希望它路由到不同的通道，这样我就可以回复不同的HTTP状态代码。如何将publish
浏览 45提问于2021-03-14得票数 0
回答已采纳
我试图使用与DSL和lambda实现以下功能： }
public DirectChannel errorChannelTransformerChannel2();
浏览 1提问于2015-03-11得票数 1
回答已采纳
我的问题是订阅了一个额外的MessageHandler，这是一个。它是用ERROR级别实例化的。所以我看到了每条记录es错误的消息。我的问题是代码不能解释这种行为。由于一些未知的原因，LoggingHandler正在订阅我的PublishSubscribeChannel，并且由于一些未知的原因，它被实例化为错误级别。KafkaProducerConfig.KAFKA_PRODUCER ) MessageHandler kafka )
浏览 1提问于2018-03-01得票数 0
回答已采纳
在spring cloud dataflow上部署我的微服务时，我得到以下日志：如何引导错误流？我的猜测是创建一个errorChannel bean (正如消息所说的)。但我没有找到任何关于它<em
浏览 7提问于2020-08-05得票数 1
当抛出异常时，我期待消息被请求。我相信当我从这个收集到的时候，我已经满足了所有的条件配置 , @Qualifier("poc.errorCha
浏览 0提问于2015-09-16得票数 0
回答已采纳
我有我的数据库日志记录器myDatabaseLogger，它在errorChannel通道中不做任何事情。System.out.println命令在errorChannel通道中工作。我的数据库记录器myDatabaseLogger可以在其他流程中工作。 如何让我的数据库记录器myDatabaseLogger在errorChannel通道中工作？下面是我的代码： @Autowired
@Qualifier("errorChan
浏览 15提问于2019-02-15得票数 1
回答已采纳
1回答
如何定义Spring？
、、、
在以前的春季集成应用程序中，我能够将订阅到应用程序errorChannel，而发送出去的失败消息将在我的(预定义的)处理程序中结束。然而，现在我正试图在一个更大的应用程序中实现相同的模式，这个应用程序有一个预先存在的内绑定设置，并且我再也不能在errorChannel上找到它了。当我启动此应用程序时，在我的包含中，我不再看到以下令人放心的消息：
No bean n
浏览 5提问于2017-09-27得票数 0
回答已采纳
我正在使用spring -cloud-stream:1.3.0开发spring启动应用程序。messages，spring-cloud-stream-binder-kafka:1.3.0.RELEASE.我使用spring集成dsl来拆分文件中的行，并使用beanio将行转换为json，要求将成功的true时创建PublishSubscribeChannel，还有一个测试用例检查是否为生产者错误通道创建了bean。当我在我的应用程序中
浏览 2提问于2017-10-19得票数 1
当启动我正在处理的spring boot集成项目时，将显示以下信息日志： No bean named 'errorChannel' has been explicitly defined.Therefore, a default PublishSubscribeChannel will be created.有没有一种方法可以只使用yaml/json参数来配置这个默认Bean的队列名称，而不需要显式地创建Bean？
浏览 320提问于2020-07-27得票数 0
我想使用taskExecutor将可配置的池大小应用于多线程taskExecutor(有效负载为taskExecutor格式)。如果转换器出现错误，我想停止链(不需要继续执行步骤3)调用其他通道，通过rest向我的核心应用程序发送xml有效负载。在这一部分中，我想应用断路器，以防在通过rest调用我的核心应用程序时出错。)
.maxConcurrentConsumers(maxConcurrentConsumers
浏览 3提问于2020-03-10得票数 0
1回答
一个转换器，侦听errorChannel并将从失败消息中提取的有效负载发送回queueChannel (将其视为处理失败消息的错误处理程序，这样就不会丢失任何信息)
return new QueueChannel(); public MessageChannel toSplitter() {
r
浏览 3提问于2018-03-01得票数 0
回答已采纳
1回答
我知道我可以为网关方法调用设置一个try/catch块，但是它只会捕获jFlow流中出现的异常，而这些异常发生在channel(routerChannel())之前的所有东西上。如何处理其他流的错误？还是整个流程？process()) .get();但是，这似乎没有帮助，因为在出现异常时，process() {
return f -&g
浏览 2提问于2016-03-27得票数 13
回答已采纳
我正在使用DSL在spring集成中开发一个API，它是这样工作的。现在我正试着向我的支持小组发送电子邮件后，我想暂停我的流程15分钟，然后自动恢复。我试着创建一个sendEmailChannel (我的errorChannel的接收者)，它对我不起作用。因此，我创建了一个如下所示的转换器方法
这段代码运
浏览 76提问于2019-06-02得票数 0
该errorChannel有一个轮询器和一个在intermediateChannel中返回错误的IntegrationFlow。当所有的流和errorChannel bean都是由Spring创建并自动自动连接时，该方案就像一个护身符。但是，当我尝试以编程方式将它们全部实例化时，只有happy path有效(kafka -> intermediateChannel -> httpOutboundGateway)，但errorChannel在启动时，日志中没有
浏览 29提问于2019-07-15得票数 1
回答已采纳
当Http-Source应用程序在kubernetes上启动时，请注意控制台中的两条消息。http-source/default": Connection refused (Connection refused); nested exception is java.net.ConnectException2019-09-15 05:17:26.773 INFO 1 --- [
浏览 2提问于2019-09-15得票数 1
4回答
我现在正在使用Spring和我的项目，特别是MessageChannel/PublishSubscribeChannel。build());}@Autowired
public void doSomethingHere
浏览 3提问于2015-08-13得票数 2
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
