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-integration 相关问题

最新问题