如何在vertx中使用Eventbus消息传递?
我遵循了vertx run eventbus_pointtopoint/receiver.rb -cluster vertx run eventbus_pointtopoint/sender.rb -cluster 那我只有: ➜ ruby vertx run eventbus_pointtopoint/receiver.rb -cluster Starting clusterin
..
message-queue相关内容
负载均衡MessageQ(ActiveMQ)
这是我的情况. 1)基于REST的Web服务(Say X)接受请求并将其放入ActiveQ 2)Q的另一侧有一个侦听器，该侦听器将读取和处理消息.这是异步的 我决定使用ActiveMQ. 但是，试图找到一种可以让Q和Q侦听器可扩展的解决方案. 1)我有很多X实例在运行.因此，Q有多个生产者. 2)点菜对我很重要. 3)由于我的REST服务的会话较少，因此我无法用相同的消息ID标记
..
讯息平台
我们正在考虑在银行环境中集成两个核心系统的消息传递平台.我们正在寻找开源选项.您使用了哪些产品，可以分享经验吗? 解决方案 如果您使用的是Microsoft，我将以MSMQ开始搜索.我已经在工作中使用MSMQ了很多次，但从未真正遇到过任何严重的问题.如果您使用的是.NET，WCF对MSMQ有很好的支持. 我还对Java JMS使用了Apache ActiveMQ，结果不一.它附带了一
..
C#MSMQ无效操作异常
我创建了一个基本应用程序来管理C#中的MSMQ. 我使用以下方法在交易消息队列中创建消息: /// /// Method to send message in message queue /// /// message queue (to) ///
..
pickle.PicklingError:无法腌制'_subprocess_handle'对象:< _subprocess_han dle对象位于0x00AAAAAAA>
我正在尝试编写测试以比较python中进程间通信的方法，而OSX和Windows给我的第一个示例带来了问题.这几乎是使用队列的手动示例. 我用python 2.7.9和3.4.1在linux上编写了所有代码.而且效果很好. #!/usr/bin/env python import multiprocessing as MP ... self.mpq_main = MP.Queue()
..
Redis队列的多个node.js消息接收器
尝试使用rsmq-worker( https://github.com/mpneuried/rsmq-worker ).必须运行多个工作程序来并行处理消息. 我们如何设置多名工作人员? 使用方法的探索- https://github.com/Automattic/kue #parallel-processing-with-cluster 解决方案 只需创建指向同一队列的RSMQ
..
Perl，PHP，Python中的消息队列
我正在处理一个包含消息队列概念的项目.现在，该项目使用的是PHP，并且使消息发送或邮件发送的延迟更多.因此，我建议使用Perl或Python脚本开发消息队列.您能建议使用PHP还是Perl或Python最好? 解决方案 一种可能的解决方案是使用 Gearman 作为队列: 您的PHP项目会将消息作为后台作业发送给Gearman；完成 齿轮工会将这些消息发送给工人 工人将处理工作-
..
基本的窗口创建
即使我以前曾经这样操作过Windows窗口，但在处理Windows窗口时还是遇到了问题，并且运行良好.在阅读了有关此问题的最常见建议之后，它仍然存在.有人可以告诉我为什么输入处理被破坏了吗? 预期行为: 创建一个名为"FirstTry"的窗口 使用PatBlt将背景设为黑色 在第一次进入主循环时以及在按下"w"之后显示一个消息框. 按下Alt + F4，Escape或“关闭"按钮
..
将路由器数据推送到分布式消息系统
查询:将路由器作为kafka群集的生产者的接口. 问题:我的路由器接口正在尝试将数据推送到运行kafka的端口. (默认为9092). 问1但是kafka经纪人可以在不创建主题的情况下接受此数据吗? 问: 2 kafka使用者可以在不指定主题的情况下提取数据吗? If yes, How ? If not, What is work around this
..
在RabbitMQ中，如何使用多条消息使用多条消息或读取队列中的所有消息，或者交换所有消息以使用特定密钥?
我想使用给定密钥从特定队列或特定交换中消耗多条消息. 因此情况如下: 发布者在队列1上发布消息1 发布者在队列1上发布消息2 发布者在队列1上发布消息3 发布者在队列2上发布消息4 发布者在队列2上发布消息5 .. 使用者使用队列1中的消息 同时获得[消息1，消息2，消息3]，并在一次回叫中处理它们 listen_to(queue_name , num_of_msg_to_fet
..
Rjms& ActiveMQ:初始化记录器时发生异常
我安装了R的Rjms软件包，因为我想将消息发送到已经为我设置的ActiveMQ消息队列(称为test).由于Rjms不在CRAN上，因此我使用 R的ActiveMQ软件包中的说明从github安装了它. 但是，我注意到了两件事.安装Rjmsjars时，我收到一条警告，提示No man pages found in package ‘Rjmsjars’.我认为这可能无关紧要，但我想以防万一.
..
重订订户-发布者系统.仅由单个订户处理消息
我有一个拥有一个发布者和几个订阅者的系统.但是某些消息应仅由单个订户处理.在我的情况下，发布者发送有关更改数据库中数据的消息，所有订阅者都可以访问相同的数据库，但是我不需要他们都更改相同的数据. 如何使用rebus来实现? PS.忘了提.我不能只订阅一个订阅者，因为订阅者可以一直在线/离线. 解决方案 但是某些消息应仅由单个订户处理 然后，您不应该将bus.Publish用
..
Azure ServiceBus:Client.Receive()对于消息>返回null. 64 KB
我正在使用包含Stream和序列化对象的BrokeredMessage.根据文档，流是不是正文的一部分，标头限制为64 KB.大约67 KB的总消息远低于 256 KB的限制表示ServiceBus队列的消息大小. 我能够发送一条消息，它以正确的消息大小显示在队列中. 发出Receive-命令后，将数据包从队列中删除，并相应地将计数器减1.但是，该操作遇到超时并返回null指针而不是B
..
是否可以使用AVRO为Kafka中的Google Pub/Sub主题定义架构?
据我所知，我们可以在Kafka上定义AVRO模式，用该模式定义的主题将仅接受与该模式匹配的数据.在接受队列之前验证数据结构非常有用. Google Pub/Sub中是否有类似内容? 解决方案 Kafka本身不验证架构，因此主题固有地没有一对字节数组和一些元数据以外的架构.在数据到达主题之前，是序列化程序是生产客户端的一部分，它执行验证.同样，在一天结束时，在PubSub中，它仅存储/
..
解决Tibco EMS和.NET API中的预取
所有内容都在Tibco EMS 5. *和.NET API的背景下 我必须处理现有的消息处理模型，该模型处于循环状态: 连接已创建/打开 会话已创建/打开 创建了消息使用者 接收方法称为 如果message！= null，则我们使用它并提交或回滚事务(在基础会话上).系统会在该模型中每隔x秒拉动一次. 我创建了一个连接工厂，以确保仅创建新的会话(如果以前的会话仍在使用
..
RabbitMQ —为什么在使用主题交换时忽略我的路由键
我正在使用RabbitMQ来协调一组服务之间的事件，如下所示: 用户管理器 希望从单独的服务中收集用户数据时发出user.collect 收听由单独服务发出的user.collected 用户收集器 在应该收集某些用户数据时监听user.collect，并且 在收集数据时会发出user.collected. 还有其他服务可以监听事件，例如 user.crea
..
RabbitMQ-为什么错误的订户会收到已发布的消息?
我有两项服务，经理和收藏家. 管理器已通过routingKey user.collected订阅了队列COLLECTED_USER，并调用了UserCollected处理程序. 收集器已通过routingKey user.collect订阅了队列COLLECT_USER，并调用了CollectUser处理程序. 可以有多个收集器，因此我已将exclusive设置为false(有关代码
..
IBM MQ和.NET中的MQRC_Q_MGR_NAME_ERROR异常
我正在使用MQ.NET类，但是当我指定正确的队列管理器时，仍然会出现以下错误. 例外: CompCode:2，原因:2058 MQRC_Q_MGR_NAME_ERROR 数据:{System.Collections.ListDictionaryInternal} 消息:"MQRC_Q_MGR_NAME_ERROR" 来源:"amqmdnet" MQQueueManager
..
Bull Queue尚未完成
是Bull的新手.我曾尝试根据他们的文档代码来运行bull.该流程正在启动，但是我的工作尚未完成，或者不确定它是否触发了完成事件?不确定在哪里犯错 在下面附加我的代码 const Queue = require('bull'); const myFirstQueue = new Queue('my-first-queue', { redis: { port: Co
..
在Websphere上部署应用程序时出现mqjbnd05错误
我重新安装了Wesphere 6.1 Fixpack23.我部署了需要MQSeries JMS Queue的应用程序.我建立了一个基于MQSeries提供程序的请求和答复队列以及一个基于MQSeries提供程序的队列连接工厂.当部署的应用程序尝试访问队列时，我收到以下错误. 任何帮助将不胜感激.谢谢！ [5/28/09 10:33:42:538 EDT] 00000033 Servle
..