我正在开发SpringCloudStream的Brooklyn.Release版本。我的用例具有多个接收器的HttpSource。当我将初学者应用程序依赖项添加到应用程序中并使用它时,如下所示:
<dependency>
<groupId>org.springframework.cloud.stream.app</groupId>
<artifactId>spring-cloud-starter-stream-source-http</artifactId>
<version>1.0.4.RELEASE</version>
</dependency>
@SpringBootApplication
@Import(HttpSourceConfiguration.class)
public class SourceApplication {
public static void main(String[] args) {
SpringApplication.run(SourceApplication.class, args);
}
}
我的聚合应用程序是
@SpringBootApplication
public class Application {
public static void main(String[] args) {
new AggregateApplicationBuilder().from(SourceApplication.class)
.via(ProcessorApplication.class).to(SinkApplication.class).args().run(args);
}
}
一直得到如下响应:
<Fault xmlns="http://localhost/">
<error>Not Found</error>
<message>No message available</message>
<path>/</path>
<status>404</status>
<timestamp>1477612242743</timestamp>
</Fault>
@SpringBootApplication
@ComponentScan(value = {"com.xxx.xxx.stream","org.springframework.cloud.stream.app.http.source"})
public class Application {
public static void main(String[] args) {
new AggregateApplicationBuilder().from(SourceApplication.class)
.via(ProcessorApplication.class).to(SinkApplication.class).args().run(args);
}
}
其余endpoint似乎没有设置,看起来您可能遇到了这个问题。对于HttpSourceConfiguration
所在的包,您需要@componentscan
(因为它来自不同的包)。
如果我将相同的SourceApplication与Rabbit Binder一起使用,它将按预期工作。
您指的是带有rabbit绑定器的开箱即用HTTP
应用程序,还是在上面的SourceApplication
中添加了rabbit
绑定器依赖项?
问题内容: 例如我有一个功能: 我怎样才能返回AJAX后得到的? 问题答案: 因为请求是异步的,所以您无法返回ajax请求的结果(而同步ajax请求是一个 糟糕的 主意)。 最好的选择是将自己的回调传递给f1 然后,您将像这样致电:
问题内容: 我在使用Ajax时遇到问题。 问题是,在获得ajax响应之前,它会返回cnt。因此它总是返回NULL。 有没有办法使正确的返回响应值? 谢谢! 问题答案: 由于AJAX请求是异步的,因此您的cnt变量将在请求返回并调用成功处理程序之前返回。 我建议重构您的代码以解决此问题。 一种方法是从AJAX请求的成功处理程序中调用调用了GetGrantAmazonItemCnt()的任何函数,此方
我想在下面返回JSON。 {“名字”:“杰基”} 新来的春靴在这里。1天大。有没有合适的方法可以做到这一点?
问题内容: 我创建了一个自定义错误类型来包装错误,以便更轻松地在Golang中进行调试。当有打印错误时它可以工作,但是现在引起了恐慌。 演示版 当我调用一个函数时,它不会返回错误,我仍然应该能够包装该错误。 预期的行为是,如果错误为nil,则应该简单地忽略它,不幸的是,它会做相反的事情。 我希望它能打印出来。而是即使错误为nil也会打印。 问题答案: 正在将err变量与nil进行比较,但实际上它是
我编写了controller,它为每个映射使用了不同的值。现在我将它简化为对所有映射使用相同的值,但是我不知道如何使test工作,因为它在每个映射上都返回404。 这里是我的控制器: 和我的测试: 404及以下所有测试结果: 在org.springframework.test.util.assertionerrors.fail(assertionerrors.java:59)在org.spring
使用StreamBridge,我将包含两种不同类型的对象的消息发送到单个Kafka主题。有没有办法定义一个能够使用两种类型消息的Spring Cloud Stream的功能消费者?