RabbitMQ 队列在创建后立即被删除。为什么?
RabbitMQ queue gets deleted immediately after creation. Why?
我正在尝试在 Azure AKS 的 K8s 集群上部署 Spring 引导微服务应用程序来生成和使用数据。
当我 运行 生产者应用程序并通过 POSTMAN 向队列生成消息时,我得到 200 OK 响应,但在 RabbitMQ 管理 UI 中,我没有队列,并且在 RabbitMQ 容器日志中我看到以下错误
o.s.a.r.c.CachingConnectionFactory : Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no exchange 'employeeexchange' in vhost '/', class-id=60, method-id=40)
无法弄清楚我做错了什么。
如果您有任何想法(或需要任何其他信息),请告诉我。
您可以使用下面的方法创建一个队列
@Bean
Queue queue() {
return new Queue(String name, boolean durable, boolean exclusive, boolean autoDelete)
参数:
name
- 队列的名称。
durable
- 如果我们声明一个持久队列(该队列将在服务器重启后继续存在),则为真
exclusive
- 如果我们没有声明独占队列则为 false(该队列将仅由声明者的连接使用)
autoDelete
- 如果服务器在不再使用时不应删除队列,则为 false
我正在尝试在 Azure AKS 的 K8s 集群上部署 Spring 引导微服务应用程序来生成和使用数据。 当我 运行 生产者应用程序并通过 POSTMAN 向队列生成消息时,我得到 200 OK 响应,但在 RabbitMQ 管理 UI 中,我没有队列,并且在 RabbitMQ 容器日志中我看到以下错误
o.s.a.r.c.CachingConnectionFactory : Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no exchange 'employeeexchange' in vhost '/', class-id=60, method-id=40)
无法弄清楚我做错了什么。 如果您有任何想法(或需要任何其他信息),请告诉我。
您可以使用下面的方法创建一个队列
@Bean
Queue queue() {
return new Queue(String name, boolean durable, boolean exclusive, boolean autoDelete)
参数:
name
- 队列的名称。
durable
- 如果我们声明一个持久队列(该队列将在服务器重启后继续存在),则为真
exclusive
- 如果我们没有声明独占队列则为 false(该队列将仅由声明者的连接使用)
autoDelete
- 如果服务器在不再使用时不应删除队列,则为 false