After updating Rabbit MQ version to 3.8 from 3.7 we start getting the below exception
on micro service start up we are getting
{"timestamp":"2021-01-07T12:41:05.738+00:00","class":"org.springframework.amqp.rabbit.connection.CachingConnectionFactory","thread-id":"main","level":"INFO","type":"createBareConnection","logMessage":"Created new connection: rabbitConnectionFactory#5b5e7036:1/SimpleConnection@1e734eee [delegate=amqp://[email protected]:5672/, localPort= 40702]"}
{"timestamp":"2021-01-07T12:41:05.740+00:00","class":"com.rabbitmq.client.impl.ForgivingExceptionHandler","thread-id":"AMQP Connection 172.40.1.237:5672","level":"WARN","type":"log","logMessage":"An unexpected connection driver error occured (Exception message: Connection reset)"}
{"timestamp":"2021-01-07T12:41:06.747+00:00","class":"org.springframework.amqp.rabbit.connection.CachingConnectionFactory","thread-id":"AMQP Connection 172.40.1.237:5672","level":"ERROR","type":"log","logMessage":"Channel shutdown: connection error; protocol method: #method<connection.close>(reply-code=503, reply-text=COMMAND_INVALID - unknown exchange type 'x-delayed-message', class-id=40, method-id=10)"}
we are using spring boot
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.5.RELEASE</version>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
we are using RabbitListener to bind and create queue
@RabbitListener(bindings = @QueueBinding(
value = @Queue(value = "state.Transaction", durable = "true", autoDelete = "false"),
exchange = @Exchange(value = "state.exchange" , durable = "true"),
key = "state.Transaction"))
rabbitmq:
host: "rabbitmq-1-xyx.internal.xzy.zzz"
password: test
username: test
and this test user has all the super permisions rabbitmqctl set_permissions -p / test "." "." ".*"
