rabbitmq

5热度

3回答

我通过单击发送按钮或按消息文本字段中的回车按钮调用方法中的代码位置如下代码片段。 // In class ChatWindow private void messageTextAreaKeyPressed(java.awt.event.KeyEvent evt) { // Event handler created by Netbeans GUI designer to call this me

0热度

1回答

如何在WCF中使用RabbitMQ？

我有一个scenerio，其中可执行文件是生产者，WCF服务是使用者。 WCF服务的工作流程如下： 1）服务调用的可执行（生产者），这是可执行的另一过程，其产生的消息转换成的RabbitMQ队列。 2）服务能够消费来自RabbitMQ的队列 3消息）返回到数据客户。 using RabbitMQ.Client; using RabbitMQ.Client.Events; using Syste

2热度

1回答

骆驼RabbitMQ默认ConnectionFactory？

我正在使用Camel在RabbitMQ中使用和生成消息。另外，我正在使用Spring引导，所以我创建了一个具有我想要的所有配置的ConnectionFactory bean。这很好用，但我必须在创建的每个端点字符串中声明bean的名称。有没有办法让骆驼默认使用这个特定的bean？

0热度

1回答

RabbitMQ同一队列的多个使用者

是否可以使用主题将消息发送到队列，并让2个使用者接收并处理相同的消息？目前，我创建了2个使用交换主题观察队列绑定的使用者，但第一个使用者使用该消息并删除该队列，而第二个使用者未收到该消息。

0热度

1回答

对于节点应用程序只需要一个RbbitMQ连接，而不是每个发布调用

每当我发布新消息时，它都会创建一个新连接。我想只有一个连接和一个通道用于所有公共电话。从rabbitmq网站阅读：某些应用程序需要多个连接到AMQP代理。但是，不希望同时打开许多TCP连接，因为这样做会占用系统资源并使配置防火墙变得更加困难。 AMQP 0-9-1连接与可被认为是“共享单个TCP连接的轻量级连接”的通道复用。但是如何？这里是我的代码： Channel.js var amqp

1热度

1回答

RabbitMq：使用auto-ack = false禁用预取（prefetch_count = 0）

是否可以使用auto-ack = false禁用预取？每次我确认一条消息时，我只想避免从队列中读取消息（预取）。我只想在我调用'consume_message'时读取消息。设置prefetch_count = 0似乎不起作用，并将其视为“无限制”。已更新：据我所知'prefetch_count'是客户端缓存的消息数（本地读入缓冲区）。例如，有一个用例：（假设有我们连接到一个队列，它有消息）

0热度

1回答

Haproxy Sockjs Websocket负载平衡和RabbitMQ负载平衡在相同的配置

我正在寻找haproxy（HAProxy版本1.5.18）配置，这将允许websocket负载平衡以及RabbitMQ负载平衡。我已经尝试了许多选择，但似乎没有工作，下面是我的HAProxy的配置文件： global log 127.0.0.1 local2 chroot /var/lib/haproxy pidfile /var/run/haprox

0热度

1回答

兔听众注释从YAML

获得队列名称目前，我有我的兔子听众标注设置为： @RabbitListener（队列=“我的队列”）是没可能在队列名称拉来自我的yaml文件。我想这样做的原因是，我可以通过更改yaml文件中的队列名称，将我的队列更改为集成测试的测试队列。看来注释必须接受一个常量字符串，有没有办法绕过这个？谢谢，

1热度

1回答

访问虚拟主机拒绝访客，使用MassTransit Sample-RequestResponse示例

我在最新的RabbitMQ服务器上使用默认配置（guest虚拟机是admin），但运行RequestResponse示例时出现下一个异常。 OperationInterruptedException：将AMQP操作被中断：AMQP近距离原因，通过同伴，代码= 530，文本=发起 “NOT_ALLOWED - 访问虚拟主机 '测试' 拒绝为用户 '客人'”，CLASSID = 10， methodI

0热度

1回答

RabbitMQ多服务器实例 - 只有一个活动消费者

我有node.js服务器，它也是rabbitmq使用者。我想扩展我的应用程序到多个实例，但只保持消费者活跃。我该怎么做？感谢