spring-integration

2热度

2回答

我想了解什么是@Bean注释豆登记的方案相当于可以说我有一个这样的类： @Configuration public class SimpleConfiguration { @Bean public BigDecimal aDecimal(String example) { return new BigDecimal(example); } } 这

2热度

1回答

spring-integratiopn重试超时在一个长过程网关

我试图重试时，我的网关超时，但我不能实现这一点。显然，重试通知正在包装请求，但不要回复。无论如何要以集成的方式实现这一点？例要点：https://gist.github.com/daniel-frank/19dfafbf3d53f4c4b1463107daac540c 最好的问候，

0热度

1回答

配置保持活动状态始终保持连接状态

我有一个tcp客户端 - 服务器应用程序，其中客户端打开一个用于一次性连接并在配置时间后断开连接的连接。我如何配置它始终保持连接的活动状态，在关闭的连接上重新连接并确保多个客户端连接对服务器开放。客户端配置： <int-ip:tcp-connection-factory id="client" type="client" host="${server.TCP.host}"

1热度

2回答

从我们的应用程序使用Spring集成接收TCP服务器的确认集成

目前我们在我们的应用程序中使用Spring Integration 2.1.0版本。申请流程如下：在应用程序执行一些操作，我们通过Active MQ得到了在字符串输出字符串。我已经使用消息驱动通道适配器和服务激活器从队列中读取数据。使用tcp-outbound-gateway在服务器（应用程序作为客户端）上成功显示该数据。问题是从服务器获取确认。创建一个新频道，并在tcp-outbou

1热度

1回答

从Spring集成调用POX Web服务

我在集成（成功）各种ReST/JSON和SOAP端点的项目中使用Spring集成。现在我需要调用一个配置为接受Plain-Old-Xml-over-HTTP的BusinessWorks实例。从“Spring Integration in Action”一书中，我得到了一个暗示我应该使用int-ws：outbound-gateway。此配置产生正确的请求，但在SOAP： <int-ws:out

0热度

1回答

在Spring集成中提取主体用户HTTP入站适配器

在我的Spring集成项目（使用基本授权的Spring Security API）中，我尝试访问Principal对象以读取用户名。这是入站网关的结构：，我不 Spring Integration and http inbound adapter, how do I extract a principal user? 尽管成功验证： <int-http:inbound-gateway reque

0热度

1回答

如何防止ListenerExecutionFailedException：监听器抛出异常

我需要做些什么来防止RabbitMQ推测的以下异常。 org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception at org.springframework.amqp.rabbit.listener.AbstractMessag

0热度

1回答

春季集成TCP按令牌分组

我正在监听带有特定端口的IP并打印出消息。示例消息如下所示： [LOG_PATTERN] ABC1025... [LOG_PATTERN] (XYZ-COULD-BE-A-MSG [LOG_PATTERN] -WITH-DASH [LOG_PATTERN] -SEPARATED-TEXT) [LOG_PATTERN] ABC1026... [LOG_PATTERN] (DEF-ANOTH

0热度

1回答

在Spring集成中记录错误文件后应继续循环

这是我的方案。我必须处理文件，并从读取对象必须执行一些业务逻辑。这些就像来自文件的行。在我的错误处理程序中，我写了第一行失败，但我必须继续下一行，并应将下一个失败行写入同一个文件。但是，一旦抛出第一个异常并写入失败的行，就会退出循环。有什么办法来处理这个？

0热度

1回答

在Spring批处理中排队作业实例

我们在每个工作日的Spring批处理中都有一个作业，由另一个系统触发。有时在同一天有几个工作实例要运行。每个人都从另一个系统触发。每个作业运行约一个小时，如果有多个作业实例要运行，我们会遇到一些数据问题。我们希望如下优化此步骤，如果没有作业实例正在运行，那么启动一个新的作业实例，如果有作业实例正在运行已经将新的作业放入队列中。每个作业实例必须在下一个作业触发前完成。如果一个人失败，下一个人必须