Update Barrier for Modern Boot Versions
- publisher confirms/returns now supported in app.props.
This commit is contained in:
@@ -18,7 +18,6 @@ package org.springframework.integration.samples.barrier;
|
||||
|
||||
import java.util.Collections;
|
||||
|
||||
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
|
||||
import org.springframework.boot.Banner.Mode;
|
||||
import org.springframework.boot.SpringApplication;
|
||||
import org.springframework.boot.WebApplicationType;
|
||||
@@ -38,12 +37,6 @@ public class Application {
|
||||
public static void main(String[] args) throws Exception {
|
||||
ConfigurableApplicationContext server = SpringApplication.run(Application.class, args);
|
||||
|
||||
// https://github.com/spring-projects/spring-boot/issues/3945
|
||||
CachingConnectionFactory connectionFactory = server.getBean(CachingConnectionFactory.class);
|
||||
connectionFactory.setPublisherConfirms(true);
|
||||
connectionFactory.resetConnection();
|
||||
// https://github.com/spring-projects/spring-boot/issues/3945
|
||||
|
||||
SpringApplication application = new SpringApplicationBuilder()
|
||||
.web(WebApplicationType.NONE)
|
||||
.bannerMode(Mode.OFF)
|
||||
|
||||
@@ -1 +1,4 @@
|
||||
spring.output.ansi.enabled=always
|
||||
|
||||
spring.rabbitmq.publisher-confirms=true
|
||||
spring.rabbitmq.publisher-returns=true
|
||||
|
||||
Reference in New Issue
Block a user