-
如果容量已满并且有新消息到来,队列通道顺序如何工作?
我的队列容量无限制。我可以限制容量,但是我的问题是将按什么顺序处理消息。如果队列中有100,000条 -
Http.outboundGateway上的Spring Integration DSL OAuth
我对Spring-Integration有点陌生,并一直在尝试POC一些简单的任务。从未接触过OAuth并需要OAuth提供休息服务 -
如何在Spring集成ServiceActivator上触发多个输出通道?
是否可以在我的服务激活器上触发两个输出通道? <pre><code>@ServiceActivator(inputChannel = Constants.CHANNEL_INP -
Spring集成流SFTP:模式过滤器不起作用
我有以下初始弹簧集成流程: <pre><code> final var inboundStreamingAdapter = Sftp.inboundStreamingAdapter(new SftpRemot -
当所有bean都标记为Lazy时,Spring Boot应用程序无法启动,因为它找不到错误通道
在Spring Boot 2.2中,您可以默认将所有bean标记为惰性。 如果我通过以下方式打开 <code>spring.ma -
Spring Integration-服务参与者在文件写入操作中引发错误
我目前正在编写一个示例测试程序来获取文件,然后简单地移至另一个目录(我将添加代码来处理文件 -
从Spring Boot 2.1.9升级到2.2.1(Spring Integration)后的ClassCastException
我有一个使用Spring Integration的Spring Boot项目。我从Spring Boot 2.1.9.RELEASE升级到2.2.1.RELEASE,现在我的应用程 -
Spring Integration Java DSL错误发现参数类型不明确
我是spring集成dsl的新手。 作为学习的一部分,我将一种XML转换为Java DSL配置 这是xml配置的 -
线程轮询jdbc:inbound-channel-adapter回滚事务,但发送了MQ消息
我正在使用<em> jdbc:inbound-channel-adapter </em>作为<em> transactional </em>来轮询<strong> 50个数据库记录</strong>。 -
Spring集成Java DSL Dispatcher没有订阅者
即使在将订户添加到我的频道(即orderDeliveredChannel)之后,我仍然收到以下异常消息。 我正在将XM -
Spring Integration中的WebFlux出站网关错误处理
我试图了解如何在Spring Webflux集成中在出站网关中处理错误。 在春季集成中<strong>没有</strong> webflu -
TcpInboundGateway服务器配置-超时时将发送自定义消息
我正在将Spring Integration与Spring Boot结合使用。我有一个带有TcpInboundGateway设置的TCP服务器和一个包含业务 -
需要带有轮询器的序数群集入站通道适配器[不适用于ftp]。仍然找不到
在遗留项目的群集环境中设置入站通道适配器时遇到麻烦。 每个节点都在运行代码,但结果却很糟糕。< -
Spring TCP Integration的TcpOutboundGateway超时等待响应异常
目前,我正在通过<code>Spring Integration TCP</code>进行外部供应商集成,在该集成中,我通过创建以下两个IP -
Spring集成-部署到Pivotal Cloud Foundry中时,Wiretap不会记录日志
当消息流通过通道时,我们正在尝试使用窃听拦截器记录消息。窃听可以在本地运行时以某种方式完美 -
org.springframework.integration.gateway.MessagingGatewaySupport.throwMessageTimeoutException(MessagingGatewaySupport.java:571)
我使用publishSubscribeChannel并设计了一个threadPoolExecutor来处理一些耗时的逻辑(大约1分钟),并具有异步 -
如何在不使用Spring Boot的情况下使用Spring Integration从sftp服务器下载文件
我有一个条件,我想使用spring集成,但是<strong>不想使用spring boot </strong>从sftp服务器下载文件。 我在这 -
集成数百种SOAP服务-Spring Boot
我有一个系统(一种聚合器),该系统与数百种不同的SOAP服务集成在一起-大多数服务具有相同的业务功 -
Spring集成-使用Java配置转换服务激活器
我尝试将Spring Integration示例(<a href="https://github.com/spring-projects/spring-integration-samples/tree/master/basic/helloworl -
春季全球客户拦截器
我有一个使用大量客户服务的旧版应用程序。最近,需要为每个请求添加一个自定义的http安全标头。一 -
在WildFly 15中启动Spring Boot 2.2.1时出错-Jackson StreamFactory验证错误
我是Spring Boot的新手。我试图在WildFly 15上部署Spring Boot 2.2.1项目作为战争。我可以在Maven中构建和运行单 -
每当Spring Integration Poller触发时写入日志
每当Spring Integration Poller轮询事件触发时,是否有一种方法来记录调试语句?我正在尝试找出我的轮询器 -
如何启用Spring Integration DSL流的日志记录
即使启用了 <em> INFO </em>的信息,也不会记录日志 <em> org.springframework.integration </em> <pre><code>IntegrationF -
Spring Integration +向Kafka发送2个事件
我有一个消息网关,它在输入通道中接收http Json请求。 作为同一请求,我想向kafka发送2个事件, -
在处理程序返回null的情况下如何避免流停止?
我有以下配置: <pre><code>flow -> flow.handle(myHandler) .filter(p -> { log.warn(&# -
http入站网关可以做类似拦截器的preHandle和postHandle吗?
当服务接受http请求时,我想在MDC中放入“ UUID”。 因为它方便了日志搜索。 我继承了HttpRequestHandl -
java.lang.UnsupportedOperationException:如果我在处理程序中添加标头,则MessageHeaders是不可变的
我的处理程序中有以下一行: <pre><code>headers.put(EMPTY_FILE, true); </code></pre> 原因是 <pre><code>2019-1 -
使用Spring Integration使用tcp-connection-factory将ssl-context-support作为条件
我正在使用spring-integration-ip-3.0.8.RELEASE jar进行TCP连接。 我的要求是有条件地启用SSL支持。 我正在使用以 -
入站通道适配器未根据执行程序扩展
我有jdbc:inbound-channel-adapter轮询50条记录。 我试图通过将pollerExecutor池大小缩放到1-10来提高性能,以便 -
使用Spring Integration通过电子邮件读取文件并发送内容
我是Spring Integration的新手,我希望阅读文件的内容并将其用作电子邮件的正文。这使用的是Spring的最新