diff --git a/spring-webflux-amqp/pom.xml b/spring-webflux-amqp/pom.xml
index a8346458a0..88f5eff403 100755
--- a/spring-webflux-amqp/pom.xml
+++ b/spring-webflux-amqp/pom.xml
@@ -1,62 +1,76 @@
- 4.0.0
- org.baeldung.spring
- spring-webflux-amqp
- 1.0.0-SNAPSHOT
- spring-webflux-amqp
- jar
- Spring WebFlux AMQP Sample
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ 4.0.0
+ org.baeldung.spring
+ spring-webflux-amqp
+ 1.0.0-SNAPSHOT
+ spring-webflux-amqp
+ jar
+ Spring WebFlux AMQP Sample
-
- parent-boot-2
- com.baeldung
- 0.0.1-SNAPSHOT
- ../parent-boot-2
-
+
+ parent-boot-2
+ com.baeldung
+ 0.0.1-SNAPSHOT
+ ../parent-boot-2
+
-
-
- org.springframework.boot
- spring-boot-starter-amqp
-
-
- org.springframework.boot
- spring-boot-starter-webflux
-
+
+
+
+
+ org.springframework.boot
+ spring-boot-dependencies
+
+ 2.1.3.RELEASE
+ pom
+ import
+
+
+
-
- org.springframework.boot
- spring-boot-configuration-processor
- true
-
+
+
+ org.springframework.boot
+ spring-boot-starter-amqp
+
+
+ org.springframework.boot
+ spring-boot-starter-webflux
+
-
- org.springframework.boot
- spring-boot-starter-test
- test
-
+
+ org.springframework.boot
+ spring-boot-configuration-processor
+ true
+
-
- io.projectreactor
- reactor-test
- test
-
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
-
- org.springframework.boot
- spring-boot-starter-integration
-
-
+
+ io.projectreactor
+ reactor-test
+ test
+
-
-
-
- org.springframework.boot
- spring-boot-maven-plugin
-
-
-
+
+ org.springframework.boot
+ spring-boot-starter-integration
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
diff --git a/spring-webflux-amqp/src/main/java/org/baeldung/spring/amqp/SpringWebfluxAmqpApplication.java b/spring-webflux-amqp/src/main/java/org/baeldung/spring/amqp/SpringWebfluxAmqpApplication.java
index 30614e7ee6..8a31299333 100755
--- a/spring-webflux-amqp/src/main/java/org/baeldung/spring/amqp/SpringWebfluxAmqpApplication.java
+++ b/spring-webflux-amqp/src/main/java/org/baeldung/spring/amqp/SpringWebfluxAmqpApplication.java
@@ -3,6 +3,12 @@ package org.baeldung.spring.amqp;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.web.filter.reactive.HiddenHttpMethodFilter;
+import org.springframework.web.server.ServerWebExchange;
+import org.springframework.web.server.WebFilterChain;
+
+import reactor.core.publisher.Mono;
@SpringBootApplication
@EnableConfigurationProperties(DestinationsConfig.class)
@@ -12,4 +18,19 @@ public class SpringWebfluxAmqpApplication {
SpringApplication.run(SpringWebfluxAmqpApplication.class, args);
}
+
+ /**
+ * This is a workaround for https://github.com/spring-projects/spring-framework/issues/21094
+ * @return
+ */
+ @Bean
+ public HiddenHttpMethodFilter hiddenHttpMethodFilter() {
+ return new HiddenHttpMethodFilter() {
+ @Override
+ public Mono filter(ServerWebExchange exchange, WebFilterChain chain) {
+ return chain.filter(exchange);
+ }
+ };
+ }
+
}
diff --git a/spring-webflux-amqp/src/main/resources/application.yml b/spring-webflux-amqp/src/main/resources/application.yml
index 702aaba357..3f527ce4c5 100755
--- a/spring-webflux-amqp/src/main/resources/application.yml
+++ b/spring-webflux-amqp/src/main/resources/application.yml
@@ -1,6 +1,6 @@
spring:
rabbitmq:
- host: localhost
+ host: 192.168.99.100
port: 5672
username: guest
password: guest