spring-rabbitmq

0热度

1回答

我有一个使用骆驼来设置从队列中消耗的路由的spring应用程序。我使用rabbitmq作为消息代理。现在的问题是，如果rabbitmq代理跌落连接不自动恢复。我试过启用automaticRecoveryEnabled。但我得到noSuchMethodError。我将显示用于创建连接的代码。 <camelContext xmlns="http://camel.apache.org/schem

1热度

1回答

无法使用Spring Boot向RabbitMQ队列发送简单的“Hello World”消息

我无法使用Spring Boot向RabbitMQ服务器发送消息。我没有看到任何异常。不知道发生了什么事。我对管理控制台RabbitMQ拥有管理员级访问权限，并可以查看队列是否已创建。但是我没有看到任何队列被创建。而且在控制台日志中我看到的就是这个。控制台日志： 2017-08-15 11:32:17.015 INFO 8256 --- [ main] com.study.jms.Basi

2热度

1回答

如何设置spring-rabbitmq收听消息的速率

我正在使用spring-rabbitmq，并且我可以成功获取消息。但是当我调试时，我发现监听器创建一个线程，它会每1秒询问消息。我认为速率太高，我想要做的是将速率设置为1分钟或任何其他。我搜索了很多，但没有工作我springrabbit.xml： <rabbit:listener-container connection-factory="connectionFactory" messag

0热度

2回答

spring-boot-starter-amqp将在微服务之间起作用吗？

我是Spring amqp的新手。我试图通过以下方式发送消息：https://spring.io/guides/gs/messaging-rabbitmq/ 我能够在微服务内发送消息。但无法发送消息到另一个微服务？是否预计？如果我想发送微服务之间的消息，我应该遵循的依赖关系？请帮我这里。

0热度

1回答

消息不发送，如果我不指定队列，TopicExchange，在SpringBootApplication

绑定我试图发送消息如下： rabbitTemplate.convertAndSend("my.exchange", "my.queue", "Test Message"); 并试图如下接收消息： @RabbitListener(bindings = @QueueBinding(value = @Queue(value = "my.queue", durable = "true"), excha

1热度

1回答

无法使用SprintBoot

在RabbitMQ的NACK消息，我有以下Consumer类监听队列上的传入消息，然后两个ACK和NACK他们。 ack部分工作正常，但nack不起作用。由于某种原因，所有的消息都会得到回应。 application.properties中 spring.rabbitmq.host=192.168.99.100 spring.rabbitmq.port=5677 spring.rabbitmq

0热度

1回答

在Spring AMQP

相关SimpleMessageListenerContainer一样关闭连接我目前工作的一个基于事件的异步AMQP消息监听器，像这样： @Configuration public class ExampleAmqpConfiguration { @Bean(name = "container") public SimpleMessageListenerContainer m

0热度

1回答

听兔子队列

我正在通过弹簧队列听兔子队列和我收到此错误： org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Failed to invoke target method 'orchestrate' with argument type = [class [B], value = [{[[em

0热度

1回答

如何注册一个队列，并且它是RabbitMQ和Spring的独占使用者/侦听器？

我有以下问题需要解决：我想实现一个简单的使用RabbitMQ消息传递的延迟重试机制。我有一个基础设施，可以让我延迟传递信息。我可以有任何想要在运行时利用这种延迟重试机制的感兴趣的参与者。参与者只想给我提供2个细节和消息： 1.队列名称，他们希望在延迟T秒后传递消息。 2.队列的消费者（比如消息的消费者。）我试图做到以下几点： private void startSeparateListene

0热度

1回答

解决“无法创建航线ROUTE1在：>>>要[stream.out]”在骆驼

这是我写从队列 public class Sender { public static void main(String[] args) throws Exception { CamelContext camelContext = new DefaultCamelContext(); camelContext.addRoutes(new RouteBuilder(