spring-amqp RabbitMQ dynamisch wechseln Herausgeber-bestätigt

Question

Gibt es eine Möglichkeit, Herausgeber-bestätigt pro Nachricht zu ändern? Wir haben eine Ruhe-Schicht, die die Nachricht empfängt und an RabbitMQ veröffentlicht. Basierend auf bestimmten Nachrichteneigenschaften entscheiden wir, ob die Bestätigung des Publishers erforderlich ist oder nicht.

Gibt es eine Möglichkeit zum Überschreiben, bestätigt der Herausgeber beim Senden der Nachricht?

Answer 1

Nein; Wir müssen eine Reihe von Gerüsten hinzufügen, um Rückgaben zu unterstützen. Außerdem werden Kanäle zwischengespeichert und es gibt keine Möglichkeit, die Bestätigung für einen einmal eingestellten Kanal abzuschalten. Wir müssten 2 verschiedene Caches behalten.

Wenn Sie bedingte Bestätigungen verwenden möchten, können Sie zwei Verbindungsfactorys (und Vorlagen) definieren, eine mit Bestätigungen aktiviert, eine nicht und die zur Laufzeit zu verwendende Vorlage auswählen.

EDIT

@SpringBootApplication 
public class So41131612Application { 

    public static void main(String[] args) throws Exception { 
     ConfigurableApplicationContext context = SpringApplication.run(So41131612Application.class, args); 
     context.getBean("normalTemplate", RabbitTemplate.class).convertAndSend("foo", "foo"); 
     context.getBean("confirmingTemplate", RabbitTemplate.class).convertAndSend("", "foo", "foo", 
       new CorrelationData("foo")); 
     Thread.sleep(2000); 
     context.getBean(RabbitAdmin.class).deleteQueue("foo"); 
     context.close(); 
    } 

    @Bean 
    public Queue foo() { 
     return new Queue("foo"); 
    } 

    @Bean 
    @Primary 
    public CachingConnectionFactory rabbitConnectionFactory() { 
     return new CachingConnectionFactory("localhost"); 
    } 

    @Bean 
    public CachingConnectionFactory confirmingCf() { 
     CachingConnectionFactory cf = new CachingConnectionFactory("localhost"); 
     cf.setPublisherConfirms(true); 
     return cf; 
    } 

    @Bean 
    public AmqpTemplate normalTemplate(@Qualifier("rabbitConnectionFactory") CachingConnectionFactory normalCf) { 
     return new RabbitTemplate(normalCf); 
    } 

    @Bean 
    public AmqpTemplate confirmingTemplate(@Qualifier("confirmingCf") CachingConnectionFactory confirmingCf) { 
     RabbitTemplate rabbitTemplate = new RabbitTemplate(confirmingCf); 
     rabbitTemplate.setMandatory(true); 
     rabbitTemplate.setConfirmCallback((cd, ack, cause) -> { 
      System.out.println("Correlation:" + cd + " ack: " + ack); 
     }); 
     return rabbitTemplate; 
    } 

}