Блог

У меня следующий поток:

 @Bean
public IntegrationFlow workerInfoJmsOut(ConnectionFactory connectionFactory, WorkerProperties properties) {
  return IntegrationFlows
    .from(ChannelNames.WORKER_INFO)
    .handle(Jms.outboundAdapter(connectionFactory)
      .timeToLiveFunction(message -> properties.getHeartbeatTtl().toMillis())
      .destination(JmsQueueNames.WORKER_INFO))
    .get();
}
  

И следующий шлюз:

 @MessagingGateway
public interface DispatcherGateway {

  @Gateway(requestChannel = ChannelNames.WORKER_INFO)
  void submit(WorkerMessage message);
}
  

Которая вызывается каждые 1 секунду:

 @Scheduled(fixedDelay = 1000)
public void beat() {
  dispatcherGateway.submit(WorkerInfoNotice.of(...));
}
  

Однако точка останова в timeToLiveFunction никогда не выполняется:

Я что-то неправильно понял или почему она никогда не срабатывает?

spring-integration-jms:5.3.1.RELEASE

Я обнаружил, что мне нужно включить явное QoS

 @Bean
public IntegrationFlow workerInfoJmsOut(ConnectionFactory connectionFactory, WorkerProperties properties) {
  return IntegrationFlows
    .from(ChannelNames.WORKER_INFO)
    .handle(Jms.outboundAdapter(connectionFactory)
      .configureJmsTemplate(spec -> spec.explicitQosEnabled(true))
      .timeToLiveFunction(message -> properties.getHeartbeatTtl().toMillis())
      .destination(JmsQueueNames.WORKER_INFO))
    .get();
}