这是How to implement HTTP request/reply when the response comes from a rabbitMQ reply queue using Spring Integration DSL?的后续问题。 我们能够在本地成功构建Spring Integration应用程序和SCDF流。我们可以向rabbitMQ请求队列发送一个http请求,该请求队列被绑定到SCDF stream rabbit源。我们还可以从绑定到stream兔接收器的rabbitMQ响应队列接收返回的响应。 我们已经将SCDF流部署到绑定了内部rabbitMQ代理的PCF环境中
可以从localhost:8888访问配置服务器,但是当我在SCDF上部署应用程序时,会发生以下错误:
Fetching config from server at : http://localhost:8888
2021-07-30 14:58:53.535 INFO 143 --- [ main] o.s.b.context.config.ConfigDataLoader : Connect Timeout Exception on Url - http://localhost:8888. Will be trying the next url if avail
目前我正在使用由PCF提供的Redis。我使用JedisConnectionFactory从spring-data-redis连接到它,提供了如下所需的信任:
@Configuration
public class RedisConfig {
@Bean
public JedisConnectionFactory jedisConnectionFactory() {
final JedisConnectionFactory jedisConFactory = new JedisConnectionFactory();
jedisConFacto
我有一个Spring jar,它已经成功地部署到运行在PCF上的SCDF中。我已经为它创建了一个定义,因此可以从仪表板上运行它。fwiw使用Spring从数据库中读写。
我现在正试着把它设置成一个有计划的运行方式,并且有问题。我创建了一个包含一个触发器任务源和一个任务启动程序-本地接收器的流,并将该触发器任务URI配置为指向fat jar (通过http,使用一个静态文件PCF推送应用程序)。
仪表板显示了两个PCF应用程序(一个用于触发任务,一个用于任务本地启动程序)都已成功启动,并且全部运行,但每次出错时任务都会失败:
Caused by: java.io.IOException: Can