问题标签 [spring-dsl]

我正在尝试为 Apache Camel 实现静态代码分析，不仅适用于 java，还适用于基于 XML 的 DSL。是否有任何可用的 SCA 工具？

在 spring integration dsl 的当前版本 1.0.2 中，我可以看到一些基本通道不存在，例如 ReST/HTTP、TCP/UDP、JDBC、MQTT 等。

只是想知道这个协议/通道是在路线图中还是被故意排除在外。

PS：我可能对发布的问题听起来很愚蠢，但只是想知道原因。

我不断收到以下代码的异常：

org.springframework.integration.MessageDispatchingException：调度程序没有订阅者

有人可以帮忙吗

全栈跟踪

我正在点击此端点向 topicChannel 发送消息：

控制器

服务

这是我的代码片段

下面是错误

java.lang.RuntimeException：在 org.springframework.integration.mongodb.inbound.MongoDbMessageSource.onInit(MongoDbMessageSource.java:176) 在 org.springframework.integration.expression.ExpressionUtils.createStandardEvaluationContext(ExpressionUtils.java:79) 没有 beanfactory .springframework.integration.context.IntegrationObjectSupport.afterPropertiesSet(IntegrationObjectSupport.java:150) at com.gap.si.configuratoin.MongoDBConfiguration.getEmpDetails(MongoDBConfiguration.java:48) at com.gap.si.configuratoin.MongoDBConfiguration$$EnhancerBySpringCGLIB$ $8e22c38.CGLIB$getEmpDetails$3() at com.gap.si.configuratoin.MongoDBConfiguration$$EnhancerBySpringCGLIB$$8e22c38$$FastClassBySpringCGLIB$$99782c25.invoke() at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228) at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:309) at com.gap.si.configuratoin.MongoDBConfiguration$$EnhancerBySpringCGLIB$$8e22c38.getEmpDetails() at sun.reflect. NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在 java.lang.reflect.Method.invoke(Method. java:483) 在 org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:588) 在 org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1014) 在 org.springframework.beans 的 org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1119) .factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:504) 在 org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476) 在 org.springframework.beans.factory.support.AbstractBeanFactory $1。 getObject(AbstractBeanFactory.java:303) 在 org.springframework.beans.factory.support.DefaultSingletonBeanRegistry。getSingleton(DefaultSingletonBeanRegistry.java:230) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:299) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194)在 org.springframework.integration.config.annotation.ServiceActivatorAnnotationPostProcessor.createHandler(ServiceActivatorAnnotationPostProcessor.java:54) 在 org.springframework.integration.config.annotation.ServiceActivatorAnnotationPostProcessor.createHandler(ServiceActivatorAnnotationPostProcessor.java:54) 在 org.springframework.integration.config.annotation. .annotation.AbstractMethodAnnotationPostProcessor.postProcess(AbstractMethodAnnotationPostProcessor.java:117) 在 org.springframework.integration.config。annotation.MessagingAnnotationPostProcessor$1.doWith(MessagingAnnotationPostProcessor.java:151) at org.springframework.util.ReflectionUtils.doWithMethods(ReflectionUtils.java:495) at org.springframework.util.ReflectionUtils.doWithMethods(ReflectionUtils.java:502) at org. springframework.integration.config.annotation.MessagingAnnotationPostProcessor.postProcessAfterInitialization(MessagingAnnotationPostProcessor.java:131) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsAfterInitialization(AbstractAutowireCapableBeanFactory.java:422) at org.springframework.beans.factory.support。 AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1579) 在 org.springframework.beans.factory.support。AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:539) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476) at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java :303) 在 org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:299) 在 org.springframework.getSingleton(DefaultSingletonBeanRegistry.java:230)。 beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194) 在 org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:755) 在 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480) 在 org.springframework.boot.context.embedded 的 org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757) .EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118) 在 org.springframework.boot.SpringApplication.refresh(SpringApplication.java:686) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:320) 在 org.springframework。 boot.SpringApplication.run(SpringApplication.java:957) at org.springframework.boot.SpringApplication.run(SpringApplication.java:946) at com.gap.si.configuratoin.Application.main(Application.java:16)springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480) at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh( EmbeddedWebApplicationContext.java:118) 在 org.springframework.boot.SpringApplication.refresh(SpringApplication.java:686) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:320) 在 org.springframework.boot.SpringApplication.run (SpringApplication.java:957) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480) at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh( EmbeddedWebApplicationContext.java:118) 在 org.springframework.boot.SpringApplication.refresh(SpringApplication.java:686) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:320) 在 org.springframework.boot.SpringApplication.run (SpringApplication.java:957) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480) at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118)在 org.springframework.boot.SpringApplication.refresh(SpringApplication.java:686) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:320) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:957 ) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480) at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118)在 org.springframework.boot.SpringApplication.refresh(SpringApplication.java:686) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:320) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:957 ) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)第757章.refresh(SpringApplication.java:686) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:320) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:957) 在 org.springframework.boot。 SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)第757章.refresh(SpringApplication.java:686) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:320) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:957) 在 org.springframework.boot。 SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)Embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:686) at org.springframework.boot.SpringApplication.run(SpringApplication.java:320) at org.springframework .boot.SpringApplication.run(SpringApplication.java:957) at org.springframework.boot.SpringApplication.run(SpringApplication.java:946) at com.gap.si.configuratoin.Application.main(Application.java:16)Embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118) at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:686) at org.springframework.boot.SpringApplication.run(SpringApplication.java:320) at org.springframework .boot.SpringApplication.run(SpringApplication.java:957) at org.springframework.boot.SpringApplication.run(SpringApplication.java:946) at com.gap.si.configuratoin.Application.main(Application.java:16)java:957) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)java:957) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:946) 在 com.gap.si.configuratoin.Application.main(Application.java:16)

在 Spring Integration Java DSL 中使用 WSInboundGateway 时，有没有办法提取标头（其值）并使用它来填充枚举？

我已经尝试过了，但 SpEL 没有评估：

我有以下配置

通道 3 是一个 pub-sub 通道，有 2 个消费者处理消息并在完成后将消息放入 aggregatorInputChannel。然而，我观察到的是，即使消息最终被放入了 aggregatorOutputChannel（我通过聚合器 bean 定义进行了调试，我可以看到消息进入 aggregatorOutputChannel），channel3 上的网关阻塞并且永远不会返回。结果，消息永远不会到达通道 4。

我在这里错过了什么吗？还是做错了什么？

AggregationMessageGroupProcessor 是我的自定义聚合器，我在其中所做的只是覆盖 aggregatePayloads 方法

谢谢！

我正在尝试使用 Spring DSL 进行一些路由。我无法将消息发送到目的地。我知道我遗漏了一些东西，请帮助我找出问题所在。我在 deviceMessageRouteIdentifier 中设置了标题，如下所示

我的骆驼路线在这里

我能够到达 deviceMessageRouteIdentifier 但无法到达目的地 gen2BridgeProcessor

提前致谢

我正在尝试调整以下示例： https ://github.com/joshlong/spring-and-kafka

使用以下库的最新稳定版本：

集成 dsl 库似乎经历了重构，这可能是由于引入了新的 KafkaProducer。

这是我的生产者配置的代码：

以及消息生成的代码：

那是我得到的例外：

更新：
完整的工作源代码可以在我的 fork 中找到：
https ://github.com/magiccrafter/spring-and-kafka

我想在外部属性文件的多播标记中设置超时属性。我可以在 uri 等定义中

使用{{property.name}}语法而没有问题的属性。

但是下面的用法似乎是不允许的。任何想法如何解决/正确的方法？

我想使用 Spring Boot 和 Integration DSL 将消息作为 HTTP Post 发送到休息服务。有没有人有一个如何通过（基本）身份验证做到这一点的例子？

其他一切似乎都运行良好。日志显示“org.springframework.web.client.HttpClientErrorException: 401 Unauthorized”。