spring集成:无法查找名为'errorChannel‘的MessageChannel
Spring集成是一个用于构建企业级应用程序的开发框架。它提供了一种简化和加速应用程序开发的方式，通过集成各种技术和组件，包括前端开发、后端开发、软件测试、数据库、服务器运维、云原生、网络通信、网络安全、音视频、多媒体处理、人工智能、物联网、移动开发、存储、区块链、元宇宙等。
在Spring集成中，'errorChannel'是一个MessageChannel，用于处理应用程序中的错误消息。当应用程序发生错误时，错误消息会被发送到'errorChannel'，然后可以根据需要进行处理。这种机制可以帮助开发人员更好地管理和处理应用程序中的错误情况。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云函数 SCF：https://cloud.tencent.com/product/scf
- 腾讯云消息队列 CKafka：https://cloud.tencent.com/product/ckafka
这些产品可以与Spring集成一起使用，提供可靠的消息传递和处理机制，帮助开发人员构建高可靠性的应用程序。
相关·内容
我在这个配置中使用Spring集成：
@Bean MessageChannel errorChannel(){
return new PublishSubscribeChannel();
}
@MessagingGateway(name = "gatewayInbound",
defaultRequestChannel="farsRequestChannel", errorChannel="errorChannel"){
}
使用此配置，我避免显示消息，但我希望创建一个基本日志，如LOGGER.error()。
此外，我正在与SLFJ
浏览 0提问于2014-12-16得票数 4
回答已采纳
1回答
AMQP弹簧集成错误处理
、、、、
我有一个集成流程，如下所示：
@Bean
public IntegrationFlow auditFlow(@Qualifier("eventLoggingConnectionFactory") ConnectionFactory connectionFactory,
@Qualifier("writeChannel") MessageChannel messageChannel,
@Qualifier("parseErro
浏览 1提问于2015-09-24得票数 3
回答已采纳
1回答
我正在尝试将下面的代码转换为spring集成的java dsl。
<int:channel id="partsSubscriberChannel" />
<int-jms:message-driven-channel-adapter
id="jmsPartsInbound"
acknowledge="transacted"
destination-name="parts.topic"
channel="partsSubscriberChanne
浏览 1提问于2015-07-28得票数 0
回答已采纳
我有一个spring集成消息存储在数据库中。此消息是在发生异常后存储的，并由errorChannel捕获。 现在，当我尝试使用控制总线重放此消息时，如果发生异常，我会在日志中看到一个错误，但errorChannel没有捕获到任何异常。 下面是我使用的代码： @Qualifier("control-bus.replay.channel")
MessageChannel controlBus;
public void redo(Message<?> msg){
controlBus.send(
MessageBuild
浏览 11提问于2019-05-27得票数 0
1回答
我正在将应用程序迁移到功能方法中。到目前为止，我使用了提供的千分尺指标。见。
从迁移开始，使用StreamBridge生成的消息不再生成度量。这似乎是因为Spring在通道被定义为bean和StreamBridge动态创建通道时创建了它的度量。
话虽如此，我的问题是：
SCS是否提供其他类型的度量？
如果没有，有没有办法迫使应用程序事先将通道声明为bean？
提前谢谢。
更新
下面的测试显示，即使在属性中定义绑定目的地，bean也不会在启动时创建。
用于测试的版本如下：
弹簧-启动: 2.5.4
春云流: 3.1.3
class MessageChannelBeanTests
浏览 2提问于2021-09-09得票数 0
我们目前使用Spring Cloud Stream来提供输入的SubscribableChannel和输出的MessageChannel，并且我们使用Spring Integration来提供两个Kafka主题之间的业务逻辑。在其他Spring Integration应用程序中，我们使用errorChannel头来动态地提供错误处理通道(例如，当发生了需要回滚错误的某个更改时，更改错误通道)。 但是，Spring Cloud Stream提供的输入通道似乎不支持errorChannel头部。有没有办法实现这一点？ 示例代码(请原谅打字错误--手工复制自另一台机器) public interf
浏览 14提问于2019-06-29得票数 1
我有一些应用程序从(Brixton.RELEASE)获得它的配置，并希望启用其属性的自动刷新。我遵循Spring 配置服务器和客户端应用程序，但是，当对本地git文件进行更改时，什么都不会发生。
默认配置还检测本地git存储库中的文件系统更改(在这种情况下不使用web钩子，但一旦编辑了配置文件，刷新将被广播)。
有人能指出在Spring的代码中哪些地方可能出错或者在哪里调试来检查它吗？
Spring云服务器Config
server:
port: 8888
info:
description: Spring Cloud Config Server
spring:
app
浏览 4提问于2016-05-13得票数 2
我有一个int-aws:sqs-message-driven-channel-adapter，如果设置errorChannel，下游的异常就会出现。
但是，当我不设置errorChannel时，异常不会被记录。它不属于预期的errorChannel。有没有办法，这样的异常至少会被记录下来？是否存在可以简单记录此类错误的默认errorlogger？
更新
按照注释发布XML和DSL配置。在持久化层中通过为error上的@NotBlank字段设置null来模拟ServiceObject。
<?xml version="1.0" encoding="UTF-8"
浏览 2提问于2021-04-21得票数 1
回答已采纳
在使用@StreamListener收听kafka主题之后，在RuntimeException、全局erroChannel或主题特定errorChannel (topic.group.errors)上没有收到任何错误消息。@ServiceActivator没有收到任何信息。
POM依赖项: Greenwich.RELEASE
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactI
浏览 1提问于2019-06-07得票数 0
回答已采纳
我将消息发布到kinesis流的消息处理程序如下所示 public MessageHandler kinesisMessageHandler(final AmazonKinesisAsync amazonKinesis,
@Qualifier("successChannel") MessageChannel successChannel,
@Qualifier("errorChannel") MessageChannel errorChannel) {
KinesisMessageHandler kinesisMess
浏览 41提问于2021-11-04得票数 1
回答已采纳
我们有一个需求，当客户机调用我们的spring集成http入站网关之一时，提供给API的输入是.csv格式，一旦验证并找到正确的立即响应，就应该发送状态200 OK。如果出现错误，则发送适当的错误消息。我们使用直接和执行器通道的组合来进行异步处理。这在使用spring父版本1.2.5时工作得很好，但是当升级到1.4.0时，version.We总是会得到500个内部服务器错误，原因就像从日志中发现的MessageTimeoutException一样。
我们使用基于java的配置，配置如下。
pom.xml
<parent>
<groupId>org
浏览 1提问于2016-09-28得票数 2
1回答
如何将重构为注释支持？
、、、
我正在尝试将Spring Integration的现有xml重构为新的4.0.0.注释。
<!-- the service activator is bound to the tcp input gateways error channel -->
<ip:tcp-inbound-gateway error-channel="errorChannel" />
<int:service-activator input-channel="errorChannel" ref="myService" />
但是，如何像
浏览 3提问于2014-04-16得票数 5
回答已采纳
这是Spring Integration AWS RabbitMQ Kinesis的后续问题 我有以下配置。我注意到，当我第一次向名为kinesisSendChannel的输入通道发送消息时，将调用聚合器和发布策略，并将消息发送到Kinesis Streams。我将调试断点放在不同的位置，并且可以验证此行为。但是，当我再次将消息发布到相同的输入通道时，不会调用发布策略和出站处理器，也不会将消息发送到Kinesis。我不确定为什么只在第一次调用聚合器流，而不是为后续消息调用聚合器流。出于测试目的，将TimeoutCountSequenceSizeReleaseStrategy设置为计数为1，时
浏览 28提问于2021-10-12得票数 0
回答已采纳
我们使用spring-批处理集成从目录处理.json文件.有必要在失败后停止处理，找出问题(用问题或其他解决方案更改文件)，然后继续。当前配置在错误之后继续轮询。怎么改呢？或者，对于这种情况，可能有不同的方法。
@Configuration
@IntegrationComponentScan
@EnableIntegration
public class IntegrationConfig {
private @Autowired Job job;
@Bean
@ServiceActivator(inputChannel = "jobChannel",
output
浏览 0提问于2018-05-19得票数 1
回答已采纳
我在用
弹簧集成4.1.2.
Spring 1.4.3.
当抛出异常时，我期待消息被请求。我相信当我从这个收集到的时候，我已经满足了所有的条件
在文章中，我了解到有三个条件可以确保请求: 1) acknowledge-mode必须是自动的。2) requeue-rejected必须为真。3)抛出除AmqpRejectAndDontRequeueException以外的任何异常。
我相信在我编写的一些测试代码中，我满足了这些条件：
配置
服务激活器是引发不从AmqpRejectAndDontRequeueException继承的异常的地方。
@Autowired
public void setS
浏览 0提问于2015-09-16得票数 0
回答已采纳
我有以下Spring Integration配置，它允许我从MVC controller调用网关方法并让Controller返回，而集成流将在不阻塞controller的单独线程中继续。
然而，我不知道如何让我的错误处理程序在这个异步流中工作。我的网关定义了错误通道，但由于某些原因，我的异常无法到达它。相反，我看到LoggingHandler被调用了。
@Bean
IntegrationFlow mainInteractiveFlow() {
return IntegrationFlows.from(
MessageChannels.executor("
浏览 9提问于2016-08-12得票数 4
回答已采纳
我们正在开发一个Spring Boot (2.4.0)应用程序，它使用Spring Integration framework(5.4.1)来构建SOAP集成流并动态注册它们。使用‘FlowContext’注册‘IntegrationFlow’所需的时间随着注册的流数量的增加呈指数级增长。以下是注册流所用时间的快速快照：
5流- 500毫秒100流- 80秒300流- 300秒
我们看到，前几个流需要大约100ms才能注册，当它达到300ms时，注册每个流需要7秒。这些流在本质上是相同的(它们只是记录一条info消息并返回)。
任何帮助解决这个问题的人都将不胜感激。
SoapFlowsAuto
浏览 41提问于2021-03-05得票数 2
我是春季集成的新手，我使用以下代码，
package services.api;
public interface GreetingService {
public void greetUsers(String userName);
}
package services.impl;
import services.api.GreetingService;
public class GreetServiceImpl implements GreetingService {
@Override
public void greetUsers(String use
浏览 21提问于2014-03-04得票数 2
回答已采纳
我们在我的应用程序中使用Spring集成。我想把一些对象放到通道中进行异步处理和错误处理。为此，我为MessageGateway配置了错误通道和PollableChannel，用于处理要处理的对象。
问题所在
因此，我打电话给messageGateway.processMessage(message)，将消息发送到频道。这如预期一样工作-调用此方法是非阻塞的，消息被处理并被转发到下一个通道。但是，当处理方法抛出异常时，它不会重定向到错误通道。
另一方面，当我将处理通道从PollableChannel更改为SubscribableChannel时，错误通道正常工作，但是调用网关当然是阻塞的。我遗
浏览 2提问于2016-11-02得票数 3
回答已采纳
1回答
我的流设置如下所示：
<int:channel id="channel1">
<int:queue/>
</int:channel>
<int:channel id="channel2">
<int:queue/>
</int:channel>
<int:chain id="chain1" input-channel="channel1" output-channel="channel2">
<int
浏览 1提问于2016-08-19得票数 1
回答已采纳
我是spring集成的新手。我正在为我们的项目评估Spring Integration。我遇到了一个关于如何处理异常的问题。
我正在使用publishSubscribeChannel来处理消息。我不知道这是不是一个正确的方法。当异常在publishSubscribeChannel中抛出时，我希望它路由到不同的通道，这样我就可以回复不同的HTTP状态代码。
如何将publishSubscribeChannel中的异常路由到errorChannel。
我有以下代码。我曾尝试在代码的不同区域使用routeException，但没有成功。有人能帮我解决这个问题吗？
@Configuration
@En
浏览 45提问于2021-03-14得票数 0
回答已采纳
我正在尝试使用Kotlin的Spring Cloud Stream。我编写了一个简单的消费者，如下所示：
@Bean
fun log(): Consumer<Person> {
return Consumer<Person> { person: Person -> println("Received: ${person.name}") }
}
Spring Cloud Stream没有找到这个消费者，立即退出。它不会给出错误，而只是终止。
如果我用Java编写与下面完全相同的使用者，Stream Cloud Stream会找到这个使用者并使
浏览 345提问于2020-05-26得票数 1
我在我的应用程序中使用Spring Boot Java。应用程序正在使用MessageChannel向Kafka发送一些消息。例如:this.messageChannel.send(消息)。 我想在集成测试中模拟这个消息通道调用，这样消息就不会发送到Kafka。目前正在使用Wiremock进行Spring集成测试。 请给我建议模拟MessageChannel发送方法的方法
浏览 27提问于2021-08-06得票数 0
我正在尝试使用rabbitmq构建一个带有spring cloud stream的事件驱动的微服务。在我的例子中，rabbitmq在docker中运行。
用于在容器下运行的Docker命令
docker run -d --hostname my-rabbit --name some-rabbit --publish 15672:15672 rabbitmq:3
然后，为了启动management-plugin，我使用下面的命令进入容器的bash模式：rabbitmq-plugins enable rabbitmq_management
CONTAINER ID IMAGE
浏览 1提问于2017-05-29得票数 3
我有以下的工作套接字服务器配置，并希望添加一个处理程序，如果发生任何异常，如在Deserializer阅读期间的消息。
因此，我添加了一个@ServiceActivator(inputChannel = "errorChannel")。但是该方法从未被调用过。为什么？
@MessageEndpoint
public class SocketEndpoint {
@ServiceActivator(inputChannel = "mainChannel")
public String handleMessage(String message) {
浏览 0提问于2018-06-14得票数 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
我有一个Kafka消费者，我正在使用Spring Cloud Stream Source.class绑定和InboundChannelAdapter实现它。此Source.class定义了3个MessageChannel bean: output、nullChannel和errorChannel。我的代码如下所示：
@EnableBinding(Source.class)
@Import(KafkaSourceConfig.class)
public class KafkaSource {
@Autowired
MessageChannel controlBusChannel
浏览 23提问于2021-06-11得票数 0
回答已采纳
我是使用Java进行spring集成的初学者，我正在处理以下代码：
@EnableIntegration
@Configuration
@EnableAutoConfiguration
@IntegrationComponentScan
public class testing {
public static void main(String[] args) throws Exception {
ConfigurableApplicationContext ctx = new SpringApplicationBuilder(org.springframework.in
浏览 0提问于2017-09-19得票数 1
回答已采纳
我正在使用，并有一个简单的网关：
@MessagingGateway(name = "eventGateway", defaultRequestChannel = "inputChannel")
public interface EventProcessorGateway {
@Gateway(requestChannel="inputChannel")
public void processEvent(Message message)
}
我的spring集成流程被定义为：
@Bean MessageChannel inputChann
浏览 0提问于2015-08-04得票数 1
回答已采纳
1回答
我将遗留的tcp服务器代码迁移到spring中，并添加了基于spring集成(基于注释)的依赖项来处理tcp套接字连接。
我的入站通道是tcpIn()，出站通道是serviceChannel()，我已经创建了一个自定义通道exceptionEventChannel()来保存异常事件消息。
我有一个自定义的序列化程序/反序列化方法(ByteArrayLengthPrefixSerializer()扩展了AbstractPooledBufferByteArraySerializer)，还有一个MessageHandler @ServiceActivator方法将响应发送回tcp客户端。
//Spr
浏览 0提问于2019-03-10得票数 1
回答已采纳
流动：
使用发布子channelAggregate发布结果将Ingestion队列发布到Queue One和'Queue 2‘并行地从Ingestion队列发布到Queue One和Queue Two中的任何一个失败，将异常抛给SqsMessageDrivenAdapter以触发NO_REDRIVE行为。Ingestion-Dead-Letter队列重新驱动maxReceiveCount=3，该消息的发布将被DLQ发送到maxReceiveCount=3
在第4步之前，一切都按预期进行。但是，在步骤4中，如果不存在Queue One，则聚合器将完成，但异常不会抛出给SqsMessage
浏览 3提问于2021-06-04得票数 1
1回答
我有一个spring集成流，涉及异步执行、从网关返回值到控制器、返回值后继续集成流。
这里是网关：
@MessagingGateway
public interface GW {
@Gateway(requestChannel = "f.input")
Task input(Collection<MessengerIncomingRequest> messages);
}
下面是流程：
@Bean
IntegrationFlow jFlow() {
return IntegrationFlows.from(
Mes
浏览 2提问于2016-03-27得票数 13
回答已采纳
我们正在使用新的spring云函数库创建一个rabbitMq消费者。 但是，我们发现在应用程序启动时，我们看不到在rabbitMq实例上创建的队列或交换。 这是我们的配置。 spring:
cloud:
function:
definition: someReceiver
stream:
binders:
rabbit:
type: rabbit
bindings:
someReceiver-in-0:
consumer:
max-attem
浏览 92提问于2021-04-19得票数 0
1回答
我的Spring集成流如下所示，
从目录读取文件
在消息中添加一个名为errorChannel的标题：‘exceptionChannel’
执行业务逻辑
将输出打印到“成功目录”
如果步骤3出现错误，则将异常发送到exceptionChannel，并写入“失败目录”。我希望错误流被委托给一个单独的线程.
我拥有的：如果有5个文件，而第三个文件有一个错误，
-> 2文件被写入成功目录。
将-> 1文件写入失败目录。
->在错误文件之后停止流。
我需要的：，如果有5个文件，而第三个文件有错误，
必须将->前2个文件写入成功目录
必须将->第3号
浏览 0提问于2019-09-03得票数 0
回答已采纳
我有兴趣了解spring集成标记中使用的类，这样我就可以通过类的javadoc获得更多的标签细节。
我有两个基本问题：
spring集成xml标记(例如stdin-通道适配器)是否转换为<bean class=".." />标记？
如何找出与spring集成标记相关联的bean类？
以下是spring集成xml上下文文件的一个简单示例：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework
浏览 2提问于2016-07-08得票数 1
回答已采纳
1回答
如果我以这种方式定义Jms集成流，是否有一种方法可以避免在处理程序中转换消息类型？或者我应该以一种不同的方式实现JMS集成？
@EnableJms
@EnableIntegration
@Configuration
public class JmsInboundFlow {
private Logger logger = LoggerFactory.getLogger(JmsInboundFlow.class);
@Autowired
public ConnectionFactory jmsConnectionFactory;
@Autowired
private JmsMessageMy
浏览 3提问于2016-11-23得票数 2
回答已采纳
我正在尝试配置一个TCP套接字，该套接字以不同的消息以name,value格式接收数据。这些消息平均每秒钟到达，有时更快，有时更慢。
我能够设置一个工作配置，但我缺乏对Spring中实际发生的事情的基本理解。
我的配置文件如下所示：
@Configuration
@EnableIntegration
public class TCPSocketServerConfig
{
@Bean
public IntegrationFlow server(
final CSVProcessingService csvProcessingService,
@V
浏览 2提问于2020-03-17得票数 2
回答已采纳
我目前正在阅读spring集成主题。在spring集成的XML配置中遇到了一个符号/前缀--> "int“。
<int:channel id="errorChannel">
<int:queue capacity="500"/>
有人能帮我理解一下吗？我也曾在某个地方看到“si”被使用。这些前缀到底指定了什么&它们是特定于spring集成的吗？提前感谢！
浏览 0提问于2017-09-20得票数 1
我尝试在这里运行示例https://github.com/spring-cloud/spring-cloud-gcp/tree/master/spring-cloud-gcp-samples/spring-cloud-gcp-pubsub-binder-sample，我希望它能在我的默认项目上创建一个主题。Tomcat服务启动了，但甚至index.html页面都不会加载(应该会出现类似"Tomcat started on port(s)：8080 (http) with context path‘’“的消息)，所以它似乎被卡住了，在我添加了： @Autowired
private S
浏览 9提问于2019-02-15得票数 1
我使用入站通道适配器配置，通过以下方式使用消息。 @Bean
public AmqpInboundChannelAdapter itemInboundChannelAdapter(@Qualifier(value = "errorChannel") MessageChannel errorChannel,
@Qualifier(value = "itemChannel") Queue itemQueue,
浏览 28提问于2021-04-02得票数 0
回答已采纳
1回答
在完成特定重试之后，我使用spring集成来更改流。用于errorResponse的errorResponse bean如下所示：
@Bean
public IntegrationFlow errorMailResponse(@Qualifier(ERROR_CHANNEL) PollableChannel errorChannel) {
return IntegrationFlows.from(errorChannel)
.handle(MessagingException.class, (payload, headers) -> handleMessa
浏览 5提问于2022-03-17得票数 0
回答已采纳
1回答
我已经设置了春天云流卡夫卡生产者和消费者和有3卡夫卡经纪人运行。我已经将min.insync.replicas设置为4，以了解生产者错误处理是如何工作的。messagechannel.send调用立即返回，生产者日志继续表示NOT_ENOUGH_REPLICAS，这是很好的，也是预期的。
server.port: 9050
spring:
cloud:
stream:
bindings:
errorChannel:
destination: error-topic
output:
destinati
浏览 11提问于2022-05-09得票数 1
回答已采纳
在我的spring集成应用程序中，我有执行指定errorChannel的异步网关方法。
关于错误--我希望通过向errorChannel注册一个集成流来处理错误(我能够成功地处理这个错误)。
一旦错误被处理和处理，我可能需要有条件地发送到另一个通道进行进一步的处理，并在最后回复到网关。实现这一目标的最佳途径是什么？
示例->
@MessagingGateway(errorChannel = "errorChannel")
public interface OrchestrationServicesGateway {
@Gateway(requestChannel =
浏览 0提问于2019-07-03得票数 0
回答已采纳
我希望我的服务网关以同步方式将其即时流(直到最近的异步通道)中的任何错误作为有效消息(不例外)返回给服务调用方。
整个流程都在一个线程上。我的最小示例拒绝按需要工作，并且我无法找到正确的方法来使用框架来实现我的目标。请看下面的代码。
@RunWith(SpringRunner.class)
public class ErrorHandlingTests {
@Autowired
ErrorsHandlingService errorsHandlingService;
@EnableIntegration
@Configuration
static c
浏览 6提问于2021-01-25得票数 2
回答已采纳
我们真的对中的错误处理感到困惑。我们使用的是Boot 2.0.2和Kotlin。
在@Transformer中，我们抛出一个异常X。
此外，在Java流定义中，我们抛出相同的异常X
频道
@Bean(TO_BE_PROCESSED_CHANNEL)
fun toBeProcessed() = PublishSubscribeChannel(defaultExecutor())
流
@Configuration
class VideoDescriptorPersistSubflow(
val videoRepository: JdbcVideoRepository,
val in
浏览 1提问于2018-05-17得票数 0
回答已采纳
我已经创建了一个ConfigServer、ConfigServer和一个rest服务(UserService) project.All是基于Spring启动级的项目。ConfigServer，尤里卡服务器正常启动，工作正常。
对于UserService，当我创建一个gradle构建并使用命令java -jar jarname.jar运行胖jar时
该服务在Eureka服务器上注册，并显示在Eureka控制台上。
但是，当我在eclipse上运行与选择主类的java应用程序相同的UserService项目时，它会启动，但从未在Eureka服务器上注册。
在这两种情况下，比较两种情况下的启动日志，
浏览 0提问于2019-05-08得票数 0
回答已采纳
在我们的微服务应用程序中，我们将从RabbitMQ迁移到Redis。
这是我们的服务活化剂
@ServiceActivator(inputChannel = ApplicationEventChannelNames.REMOTE_CHANNEL)
public void handleApplicationEvent(@Header(value = ApplicationEventHeaders.APPLICATION_EVENT) final ApplicationEvent event,
@Payload Object m
浏览 2提问于2021-11-29得票数 1
回答已采纳
1回答
我对使用Publisher很感兴趣，在一些生产者中确认我们在一个项目中使用。我试过做一个小的PoC，但它不起作用。据我在文档中看到的，这对于Asyncrhonous Publisher确认来说是可能的，它应该和接下来的更改一样容易：
在application.yml中添加confirmAckChannel并启用errorChannelEnabled属性。
spring.cloud.stream:
binders:
rabbitDefault:
defaultCandidate: false
type: rabbit
environment.spr
浏览 0提问于2020-06-05得票数 0
回答已采纳
这个说，可以从全局errorChannel自动发送错误消息到特定的目的地，唯一需要的是设置以下属性：
spring.cloud.stream.bindings.error.destination
我真的对这部分感到困惑。仅仅添加属性不起作用(我使用RabbitMQ、Exchange和队列进行配置)。因此，我可以在我的应用程序中看到@ServiceActivator处理的错误，但它没有发送到RabbitMQ中的“RabbitMQ”交换。看起来，此属性没有为errorChannel定义出站绑定。
如果我在应用程序中显式地创建输出“错误”通道，
/**
* Error channel name.
浏览 1提问于2019-07-17得票数 0
回答已采纳
春季集成的新技术
我的目标是将消息传递到另一个通道(链处理)。
Channel1(Msg1) -(Msg1)
暗中之计
自愿性、性-性
商业、商业、金融等行业的商品、
1.无纺布(EmployeeObject)、Msg2 (DetailsObjet)、Msg3(VerificationObject)、Msg4(FinalObject)、Msg5(ErrorObject)
Each channel payloads will have different Class Objects.
如果出现异常、验证错误等情况，则需要向"errorChennal“传达相关的所有通道。
浏览 5提问于2015-10-09得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
