以下是为您整理出来关于【integration】合集内容，如果觉得还不错，请帮忙转发推荐。
您好,这是我的配置： > JVM 1.6.0_30> Spring 3.0.5版> Spring Integration核心2.0.5> S.O. Windows 7的 这是我的上下文配置：<beans:beanclass="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"lazy-init="false"><beans:property name="ignoreUnresolvablePlaceholders"value="true" /><beans:property name="location" value="classpath:etc/pds/pds.properties" /> </beans:bean><channel id="pdsre...
我在流程中有一个进行ReST API调用的部分：<int:channel id="requestChannel"/><int-http:outbound-gateway request-channel="requestChannel"reply-channel="logger"url="${api.base.uri}/data"http-method="PUT"expected-response-type="java.lang.String"/><int:logging-channel-adapter id="logger"logger-name="logger"expression="payload"level="INFO"/>我试图使用Java DSL复制它,但找不到足够的文档.任何帮助将非常感激.解...
我以前在Spring应用程序中使用了基于XML的配置. 现在,我想使用@Bean,@ Configuration等只使用基于Java的容器配置. 如何将这两个XML配置转换为基于Java的配置？<outbound-channel-adapter channel="emailChannel" ref="messageHandler"><poller><interval-trigger interval="60000"/></poller> </outbound-channel-adapter><tx:annotation-driven transaction-manager="transactionManager"/>解决方法:与简单的< bean />不同Spring ...
我已将CcAvenue Payment Gateway集成到我的交易项目中.有一个问题即.I am unable to get the status of $AuthDesc after a transaction. After contacting the customer service they replied saying there is a problem in my integration code. The file that they provided has the following code:$WorkingKey = “” ; //put in the 32 bit working key in the quotes provided here$encResponse=$_REQUEST[“encResponse”];...
如何将此代码转换为Java配置？<int-kafka:outbound-channel-adapterid="mainOutboundChannelAdapter"kafka-producer-context-ref="kafkaProducerContext"channel="mainOutboundTopicChanel"> </int-kafka:outbound-channel-adapter>解决方法:是的你可以.请找到最新的Spring Integration Java DSL： 您的情况可能如下：@Bean public IntegrationFlow sendToKafkaFlow(String serverAddress) {return f -> f.<String>split(p -> Fast...
我正在使用Spring Integration来开发我的集成方案.当我必须写一些日志来提供一些信息时,我这样写：@Bean IntegrationFlow blacklist(BlacklistService service) {return m -> m.wireTap(f -> f.handle(t -> log.info("Adding email source address in blacklist..."))).<MessageHandlingException, Blacklist>transform(p -> SourceBlacklist.of((Email) p.getFailedMessage().getHeaders().get(IntegrationConstants.MailSender.E...
我试图使用Spring Integration配置以下内容： >向频道发送消息.>将此消息发布到与n个消费者的兔子扇出(pub / sub)交换.>每个消费者都提供响应消息.>让Spring Integration在将它们返回到原始客户端之前聚合这些响应. 到目前为止,我有一些问题…… >我正在使用发布 – 订阅 – 通道来设置apply-sequence =“true”属性,以便correlationId,sequenceSize& sequenceNumber属性已设置. DefaultAmqpHeaderMapper抛弃了这些属性. DEBUG hea...
我现在正在奋斗这几天. 我在Spring-boot容器下使用SI适配器用于kafka. 我在我的机器上配置了zookeeper和kafka.我还创建了控制台生产者和消费者测试它,一切正常(我设法生成控制台消息并让控制台消费者使用它们). 我现在尝试通过Spring集成kafka出站适配器生成消息,但控制台消费者不会使用该消息 SI / Spring xd xml：<int:publish-subscribe-channel id="inputToKafka"/><int-kafka:outbound-channel-adapter id="kafkaOutboundChan...
这是我的spring集成xml：我用来学习的一个简单的东西……<int-file:inbound-channel-adapter id="executionMessageFileInputChannel"directory="file:${fpml.messages.input}"prevent-duplicates="false" filename-pattern="*.xml"><int:poller fixed-delay="20000" max-messages-per-poll="20"/> </int-file:inbound-channel-adapter><int:service-activator input-channel="executionMessageFileInputChannel"output-channel="ex...
我在这里扩展这个问题：java.io.IOException: Server returned HTTP response code: 411 for URL: https://login.live.com/oauth20_token.srf?code= 我正在开发Spring MVC Apache Oltu Salesforce Integration示例.在此示例中,我在salesforce中创建了连接的App,如下所示： 在这个例子中我使用下面： > ACCESS_TOKEN_URL =“https://login.salesforce.com/services/oauth2/token”> AUTHORIZATION_URL =“https://login.salesforce....