java - spring-amqp 不会使用 AmqpTemplate.convertAndSend() 插入消息

Question

这是一个小的 Spring 程序，它希望将一条消息插入到 rabbitmq 队列中:

public class Main {
  public static void main(String [] args) throws IOException {
    AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(QueueConfiguration.class);
    AmqpTemplate template = context.getBean(AmqpTemplate.class);
    template.convertAndSend("asdflk ...");
    context.destroy();
  }
}

ApplicationContext如下:

@Configuration
public class QueueConfiguration {

  @Bean
  public ConnectionFactory connectionFactory() {
    return new CachingConnectionFactory("192.168.1.39");
  }

  @Bean
  public RabbitTemplate rabbitTemplate() {
    return new RabbitTemplate(connectionFactory());
  }
}

当我检查服务器上队列的内容时，没有插入任何内容。我还尝试在 RabbitTemplate 上设置交换名称或队列名称，但服务器上仍然没有任何显示。

应用程序的日志没有显示任何错误，但会记录以下内容:

17:28:02.441 [main] DEBUG o.s.amqp.rabbit.core.RabbitTemplate - Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@192.168.1.39:5672/,1)
17:28:02.441 [main] DEBUG o.s.amqp.rabbit.core.RabbitTemplate - Publishing message on exchange [], routingKey = []

有什么问题吗？

Answer 1

我必须在调用 convertAndSend() 时将队列作为参数提供:

template.convertAndSend("hello2", "asdflk ...");

还在疑惑为什么spring-amqp不会抛出异常。当没有给出队列时，有人知道消息传递到哪里吗？