首页 > TAG信息列表 > spring-integration

如何从CXF端点调用Spring Integration应用程序

我正在使用Apache CXF Web服务和Spring Integration,现在我不怎么从CXF端点调用Spring Integration应用程序. 我有使用Apache Camel的经验,很容易解决这个问题.但是在Spring Integration中,我没有任何想法. 我的行代码是： >在webservices-definition-beans.xml中： <!-- Load CXF mod

弹簧集成单元测试出站通道适配器

我有以下配置 <int:channel id="notificationChannel" datatype="com.mycompany.integration.NotificationMessage"> <int:queue message-store="jdbc-message-store" capacity="1000" /> </int:channel>

java-Spring AMQP集成-用户手册确认

我正在测试具有Spring-Integration支持的Spring-AMQP,我已经进行了配置和测试： <rabbit:connection-factory id="connectionFactory" /> <rabbit:queue name="durableQ"/> <int:channel id="consumingChannel"> <int:queue capacity="

如果我的事务成功完成,如何使用Spring Integration仅发送消息？

我正在学习Spring Integration,并使用它在Grails中实现基本的电子邮件服务.我想做的是打电话给我的电子邮件服务,但只有在尝试成功发送电子邮件的交易成功后才发送电子邮件.尽管这是在Grails中完成的,但除了使用BeanBuilder DSL而不是XML配置之外,它实际上与常规的Spring应用程序没

春季-如何轮询目录中的文件？

我需要能够使用SCP轮询目录中的特定文件,并且一旦文件被处理,它就需要继续轮询. Spring Batch有可能吗？解决方法:解决此问题的通常方法是使用Spring Integration.我要解决的方法是通过Spring Integration流,该流使用SFTP入站通道适配器检索文件,然后将传输的名称传递给Spring Batch

java-通用类型和HTTP出站网关结果

因此,我有一个http出站网关,该网关正在调用给定的RESTful端点,该端点返回JSON数组. <int-http:outbound-gateway id="shipments" http-method="GET" expected-response-type="java.util.List" url="http://codeserver.net/shipments?order={orderId}&qu

java-Spring Integration Inbound-Channel-Adapter逐行读取大文件

我目前正在将Spring Integration 4.1.0与Spring 4.1.2结合使用. 我要求能够逐行读取文件并将读取的每一行都用作消息.基本上,我想允许我们的消息源之一“重播”,但是消息不是保存在单个文件中,而是保存在单个文件中.我对此用例没有交易要求.除了与JVM运行所在的服务器位于同一服务

Headerenricher Spring Integration和Java DSL

我正在使用Spring Integration和Java DSL规范来实现我的IntegrationFlow.我想使用一个自定义的头文件扩充工具来向头文件添加一些文件名,就像这样： public class FileHeaderNamingEnricher { public Message<File> enrichHeader(Message<File> fileMessage) { // g

春季-单个JMSTemplate可以在多个生产者中共享吗？

我想为连接到ActiveMQ代理的多个生产者共享JMSTemplate的单个实例.样本配置： <bean id="ProducerJmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory"> <ref bean="gloProducerJmsFactory&q

java-MarshallingWebServiceInboundGateway的问题

我正在使用带有spring-integration和spring-ws的spring-boot来提供SOAP Web服务作为集成流程的入口. 我因此配置了入站网关： @Bean MarshallingWebServiceInboundGateway entryPoint() { MarshallingWebServiceInboundGateway entryPoint = new MarshallingWebServiceInboundGa

在Java中使用Spring框架进行TCP / IP配置

我正在尝试使用Spring TCP / IP集成制作服务器套接字.但是问题是,我对使用Spring感到很陌生,在谷歌搜索后发现的解决方案对我没有太大帮助.我访问了Spring网站,他们谈论了很多我无法理解的事情.因此,如果有人可以在Spring配置和相应的Java代码方面为您提供帮助…. 顺便说一句,我正

eclipse-Spring Integration STS插件集成图“手动模式”

在多个论坛主题中,人们在集成图表选项卡中编辑spring-integration xml文件时谈论的是“手动模式”. 问题是我无法找到一种方法来访问此手动模式并更改默认提供的图形的布局(这是一团糟). 我尝试更改元素的位置,但是出现红叉,并且可以找到一个按钮,上面显示切换到手动模式或类似的内

java-Cron表达式作为聚合器发布策略

我想在我的链中放置一个聚合器,以聚合所有传入的消息(字符串),并在特定时刻释放聚合的消息(字符串),我想使用“ cron表达式”(如在投票者) 关于如何做到这一点的任何想法？ 谢谢！解决方法:由于您只想通过cron表达式从聚合器中释放消息,因此我建议您看一下MessageGroupStoreReaper,它负

java-AMQP Spring Integration错误处理

我有一个集成流程,如下所示： @Bean public IntegrationFlow auditFlow(@Qualifier("eventLoggingConnectionFactory") ConnectionFactory connectionFactory, @Qualifier("writeChannel") MessageChannel messageChannel,

弹簧-通道到多个出站通道适配器

我有一个频道 <int:channel id="myChannel" /> 为此,我希望将每条消息路由到多个出站通道适配器： <int-jms:outbound-channel-adapter id="ocaOne" channel="myChannel" /> <int-jms:outbound-channel-adapter id="ocaTwo" channel="myCha

如何在Spring集成中使用JAVA配置创建xslt-transformer？

我在Spring-Integration中有以下xslt-transformer.如何使用Java Config进行相同的配置？ <si-xml:xslt-transformer input-channel="input" output-channel="output" xsl-resource="classpath:/test.xsl"

Spring集成：SecurityContext传播

我对Spring Integration中的SecurityContext传播有些困惑. 这是文档的重点： http://docs.spring.io/spring-integration/reference/htmlsingle/#security-context-propagation 我的困惑如下： (1) To be sure that our interaction with the application is secure, according to

java-Spring Integration：通过注释配置入站通道适配器

如何通过注释而不是常规配置文件配置入站通道适配器？我可以为会话工厂定义bean,如下所示： @Bean public DefaultFtpSessionFactory ftpSessionFactory() { DefaultFtpSessionFactory ftpSessionFactory = new DefaultFtpSessionFactory(); ftpSessionFacto

java-如何在Spring集成中获取发件人IP地址？

我使用Spring集成进行Web服务消息处理.不幸的是,消息中没有发送者的IP地址.我如何获得此信息？ @Bean public SimpleWebServiceInboundGateway myInboundGateway() { SimpleWebServiceInboundGateway simpleWebServiceInboundGateway = new SimpleWebServiceInboundGateway();

弹簧-动态上下文-自动装配

我使用以下代码将上下文动态添加到应用程序上下文中： @Component @Scope("singleton") public class DynamicContextLoader implements ApplicationContextAware { private static ApplicationContext context; private Map<String, InterfacePropertyDto> contextMap;

java-使用PollableChannel时的Spring集成错误通道

我们在我的应用程序中使用Spring集成.我想将一些对象放入通道中以进行异步处理和错误处理.因此,为此,我为MessageGateway配置了错误通道和PollableChannel来处理要处理的对象. 问题 所以我在调用messageGateway.processMessage(message)将消息放入通道.这按预期方式工作-调用此方法

java-spring任意消息传递tcp套接字

我正在使用spring-integration开发定制的双向TCP套接字服务器. 服务器将处理请求/响应任务,但我无法向特定的connection-Id发送任意消息 我也知道也许使用TcpSendingMessageHandler和TcpReceivingChannelAdapter是解决方案,但是我找不到任何有关如何使用它的示例代码. 这是我的代码

java-如何发送对TCP请求的答复(spring-integration)？

我需要类似Can not send response for UDP message的内容 但对于TCP.因此客户端发送消息,TCP服务器可以像OK一样发送回响应.对于TCP socket-expression =“ @ inbound.socket”和destination-expression =“ headers [‘ip_packetAddress’]”无法使用. 这是我的配置现在的样子： <?

java-在竞争的使用者队列上侦听的多个测试应用程序上下文会导致间歇性测试失败

我有一个正在测试的JMSInboundGateway,它侦听Apache Artemis队列(竞争使用者).我的测试将消息发送到Artemis服务器,并模拟目标服务.如果调用了模拟服务,那么我已经验证了JmsInboundGateway的设置正确. 流程如下所示： 测试发件人-> Artemis Queue-> JmsInboundGateway-> DirectChanne

Spring Boot 2.0.5中来自PrometheusPushGateway的@PreDestroy批注中的BeanCreationNotAllowedException

我使用PushGatewayConfiguration进行了一些小的更改来配置PrometheusPushGateway. PrometheusPushGateway设置为在任务结束时通过@PreDestroy批注发送指标.在Spring 2.0.3中,PushGateway可以正常工作,但是在Spring 2.0.5中,我从PushGatewayHandler.shutdown()调用中获得了堆栈跟踪.