Ich versuche, eine Feder Boot-Anwendung zu starten, die RabbitMQ durch diese Konfigurationsklasse konfiguriert hat:Fehler keine Warteschlange in vhost beim Anwendungsstart
@Configuration
public class RabbitConfig implements RabbitListenerConfigurer {
public static final String AMQP_EXCHANGE_NAME = "test-queue";
@Bean
public Exchange accessExchange() {
return new DirectExchange(AMQP_EXCHANGE_NAME);
}
@Bean
public Binding binding(Queue queue, DirectExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(AMQP_EXCHANGE_NAME);
}
@Bean
public Jackson2JsonMessageConverter producerJackson2MessageConverter() {
return new Jackson2JsonMessageConverter();
}
@Bean
public MappingJackson2MessageConverter consumerJackson2MessageConverter() {
return new MappingJackson2MessageConverter();
}
@Bean
public RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory) {
final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(producerJackson2MessageConverter());
return rabbitTemplate;
}
@Bean
public DefaultMessageHandlerMethodFactory messageHandlerMethodFactory() {
DefaultMessageHandlerMethodFactory factory = new DefaultMessageHandlerMethodFactory();
factory.setMessageConverter(consumerJackson2MessageConverter());
return factory;
}
@Override
public void configureRabbitListeners(RabbitListenerEndpointRegistrar registrar) {
registrar.setMessageHandlerMethodFactory(messageHandlerMethodFactory());
}
Aber ich erhalte die Störung no queue 'test-queue' in vhost '/'
:
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'test-queue' in vhost '/', class-id=50, method-id=10)
at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:509) ~[amqp-client-4.2.0.jar:4.2.0]
at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:340) ~[amqp-client-4.2.0.jar:4.2.0]
at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:162) ~[amqp-client-4.2.0.jar:4.2.0]
at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:109) ~[amqp-client-4.2.0.jar:4.2.0]
at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:643) ~[amqp-client-4.2.0.jar:4.2.0]
at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:47) ~[amqp-client-4.2.0.jar:4.2.0]
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:581) ~[amqp-client-4.2.0.jar:4.2.0]
... 1 common frames omitted
Dieses Problem tritt nur, wenn ich die folgenden Hörer definiert habe:
@Transactional
@RabbitListener(queues = RabbitConfig.AMQP_EXCHANGE_NAME)
public void doSomething(TestDTO dto) {
...
}
Es scheint, dass ich versuche, aus der Warteschlange zu konsumieren, aber die Warteschlange wurde nicht erstellt. Wenn ich die Warteschlange über die RabbitMQ-Verwaltungsschnittstelle erstelle, tritt der Fehler nicht auf.
Gibt es eine Möglichkeit, diese Warteschlange automatisch zu erstellen, damit ich diesen Fehler nicht bekomme?