spring-integration 相关问题

我有一个jms出站通道适配器。我想向我的 Apache Artemis Broker 发送消息并添加延迟。我有一个jms出站通道适配器。我想向我的 Apache Artemis Broker 发送消息并添加延迟。 <int-jms:outbound-channel-adapter connection-factory="scheduledConnectionFactory" channel="tnpScheduledOutboundChannel" destination="tnpScheduledQueue" /> 我的将 header 添加到 spring 集成消息的 java 代码是： return MessageBuilder.withPayload(sdpInfo).setHeader("_AMQ_SCHED_DELIVERY",sdpInfo.getDelay()).build(); 标头被添加为 Spring 集成标头。但它没有被 JMS 拾取，即队列的使用者立即看到它。我需要添加某种 JmsHeaderMapper 吗？有人可以指出一些文档或示例吗？更新这是在 JmsSendingMessageHandler 中调试时捕获的消息。 ActiveMQMessage[null]:PERSISTENT/ClientMessageImpl[messageID=0, durable=true, address=null,userID=null,properties=TypedProperties[sequenceNumber=4,file_status=0,sequenceSize=0,_AMQ_SCHED_DELIVERY=14685858,timestamp=1605707114145,correlationId=4d6fa6c8-fdcb-d69b-cd60-d260264545f5]] 如果我直接在激活器中使用 jmsTemplate public void sendDelayMessage(SdpInfoTemplate<?> message, long deliveryDelay, String queue) { jmsTemplateDelay.setDeliveryDelay(deliveryDelay); jmsTemplateDelay.setDeliveryMode(DeliveryMode.PERSISTENT); jmsTemplateDelay.convertAndSend("sdp-file-tnp-scheduled-dimitris-test", message, m -> { m.setLongProperty("_AMQ_SCHED_DELIVERY", deliveryDelay); m.setStringProperty("TRANSACTION_ID",message.getTransactionId()); return m; }); 关键部分是jmsTemplateDelay.setDeliveryDelay(deliveryDelay); 如果我不设置这个，它会被调度，它会被忽略，消费者端会立即收到消息默认情况下，在 DefaultJmsHeaderMapper 中使用 JmsSendingMessageHandler。如果值属于支持的类型，它将所有标头映射到 jmsMessage.setObjectProperty(propertyName, value);： private static final List<Class<?>> SUPPORTED_PROPERTY_TYPES = Arrays.asList(new Class<?>[] { Boolean.class, Byte.class, Double.class, Float.class 或者你在中间的某个地方丢失了标题...... 更新抱歉，您让我们感到困惑。您的 _AMQ_SCHED_DELIVERY 确实作为最终 JMS 消息中的属性存在。当你谈论setDeliveryDelay()时，这是完全不同的故事。您可以做的就是扩展 DynamicJmsTemplate。覆盖其 getDeliveryDelay() 并从您填充的 ThreadLocal 中获取所需的值，然后再向该 <int-jms:outbound-channel-adapter> 发送消息。这是我们绝对可以添加到 DynamicJmsTemplate 和 DynamicJmsTemplateProperties 中以通过上述 JmsSendingMessageHandler 解决的问题。但目前的解决方法仅为此 ThreadLocal 选项实现您自己的 deliveryDelay 变量。对于此设置（Spring Integration + Artemis），如果您想延迟向消费者传递消息，您可以这样做 .setHeader(Message.HDR_SCHEDULED_DELIVERY_TIME.toString(), System.currentTimeMillis() + {yourDelayInMs}) 关键点是您应该设置从纪元开始的以毫秒为单位的交付时间，而不是实际的延迟值。

spring-integration activemq-artemis

回答 2 投票 0

启动第一个作业会导致 - 声明多个 DirectChannel 时调度程序没有频道异常订阅者

我有一个 Spring Batch 应用程序，它成功运行 Spring Batch 作业，但在声明多个 DirectChannel 时出现异常。当我启动“firstJob&...

java spring spring-batch spring-integration

回答 1 投票 0

设置了队列大小的taskExecutor如何与文件输入适配器的AcceptOnceFileListFilter过滤器一起使用

据我了解如果你有10个池大小和50个队列大小的taskExecutor，在所有线程都被占用并且队列已满并且我没有设置调用者策略的情况下，我认为......

spring-integration

回答 1 投票 0

如果在带有 XML Config 的 Spring Integration 4.2.0 中使用自定义 DirectoryScanner，如何跳过“filter”和“locker”属性的设置

在 Spring Integration 4.2.0 中，它提到如果使用自定义扫描仪，则必须存在“filter”和“locker”（以前的 https://github.com/spring-projects/spring-integration/issues/7545在...

spring-integration

回答 2 投票 0

Spring Integration JMS MessageDrivenChannelAdapter 连接状态

在 Spring 5.3.29 中，如何在未收到消息的情况下检测 MessageDriveChannelAdapter 已连接到 JMS。目前，我有； IntegrationFlows.from( 杰姆斯 .messageDrivenChannelA...

spring-integration spring-integration-dsl spring-integration-jms

回答 1 投票 0

AWS 集成 spring：延长可见性超时

是否可以延长正在传输的消息的可见时间。看： http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/AboutVT.html。部分：更改

spring spring-integration aws-sdk spring-cloud

回答 3 投票 0

使用 Java DSL 的消息传递网关的回复通道

我有一个 REST API，它接收来自客户端应用程序的 POST 请求。 @Autowired 私人 EdiTranslationEvents.TransformToStringtransformToString; @PostMapping("/testPost") @

spring-integration spring-integration-dsl

回答 1 投票 0

Spring 集成 - 无法在 BeanFactory 中查找名称为“55774d05-e054-4b71-bc7e-ecc53d029e75:20”的 MessageChannel

我有一个带有 spring 集成的 Spring boot 项目。据我了解，它使用分散-聚集模式： @豆公共 IntegrationFlow getClientsFlow() { 返回 IntegrationFlows.from(

spring-integration

回答 2 投票 0

Spring集成sftp新版本升级问题

错误日志 [sshd-SshClient[thread-4] 警告 o.a.s.c.k.AcceptAllServerKeyVerifier - 服务器上的服务器提供未经验证的 RSA 密钥：SHA256：密钥 [sshd-SshClient[thread-3] 警告 o.a.s.c.s.ClientSessionIm...

spring-boot spring-integration spring-integration-sftp apache-sshd

回答 1 投票 0

Spring 集成旋转服务器与 SFTP 出站网关的建议

我想问是否可以在 SFTP 出站网关上使用轮换服务器建议，我正在使用 SFTP 入站适配器轮询文件，并且在轮询方法中我使用轮换服务器建议。有效

spring spring-boot spring-integration

回答 1 投票 0

Springboot 3.1 和 Spring Integration 6 - IntegrationComponentScan 未扫描 MessagingGateway

将 springboot 从 2.7 升级到 3.1，并且依赖的 spring jar 升级到版本 6。升级后，spring 集成流程无法处理请求。抛出错误 - 组织。

spring-integration

回答 1 投票 0

JmsOutboundGateway 重试连接 mq -> GatewayReplyListenerContainer refreshConnectionUntilSuccessful (maxAttempts=unlimited)

我对 JmsOutboundGateway 连接超时有疑问（org.springframework.integration.jms.JmsOutboundGateway$GatewayReplyListenerContainer refreshConnectionUntilSuccessful） - 在我的 c...

spring spring-boot spring-integration

回答 1 投票 0

如果降序服务激活器出现故障，RequestHandlerCircuitBreakerAdvice 将不起作用

我对 RequestHandlerCircuitBreakerAdvice 有疑问。在下面的代码中，如果 JmsOutboundGat 出现故障时，将 RequestHandlerCircuitBreakerAdvice 添加为 passThru 和 passThruSecond 中的建议...

spring-boot spring-integration

回答 1 投票 0

Spring Integration 和 Spring Batch 事务管理器冲突

我正在使用 Spring 集成流程从文件服务器读取文件。我的应用程序将在多个实例上运行。我想确保每个实例仅处理任何文件一次。这就是我

spring-boot spring-batch spring-integration spring-jdbc

回答 1 投票 0

spring-integration 相关问题

最新问题