messagebroker

2热度

1回答

我想在PHP中使用redis pub/sub，但是我担心PHP不能成为唯一的工具：订阅者需要始终可以调用，因为php不是作为守护进程来运行的，我不能相信它可靠永远是“开”。那么，什么是对PHP世界的解决方案：不使用的pub/sub，使用其他的Redis'与crontask储存推出PHP每隔x分钟使用经纪人至极将调用PHP？其他？随着“2”我的意思是：使用一个nodejs/java/foo

0热度

1回答

在IIB消息流中向MQ消息添加自定义/命名属性

我是IIB 9.0的新手，我一直在使用Google搜索，但无法找到一个好的解决方案，以便如何将自定义/命名属性添加到IIB 9.0消息流中的MQ消息。在IBM Integration Toolkit中，有两个头节点可用于设计消息流JMSHeader和MQHeader。 JMSHeader允许我将新的自定义（应用程序）属性添加到JMS消息中，而没有任何问题。但是，MQHeader似乎没有相同的功能

0热度

1回答

（WMB）消息流可以有多个监控配置文件吗？

我需要从消息流中发出两次相同的事件（开始/结束/回滚） - 因为它们需要由需要不同数据的两种不同数据服务消耗。所以我需要两个监控配置文件应用于相同的流量。这可能吗？在实际使用数据时，我打算使用订阅过滤来区分两个配置文件发出的事件。

0热度

1回答

ActiveMQ - 仅发布有兴趣订户的数据的策略？

我有一个消息代理，各个客户将在短时间内连接一天。该券商维持可在其上发布的价格为成千上万的事情，但在任何给定的时间设定的当前连接的客户端将只关心这些事情的一小部分的话题。在一个紧密耦合的系统中，客户端会明确地订阅特定的东西，服务器会跟踪低级客户端连接/断开连接事件（自动取消订阅断开连接的客户端）并且只发布客户订阅的东西的价格。什么是在消息系统一样的ActiveMQ更加松散耦合世界处理这种事情的

0热度

3回答

ESQL XML创作IIB

有人可以帮助我在IIB 输入创建使用ESQL以下XML结构： <animal> <animaldomestic>dog<animaldomestic> <animalwild>cheetah<animalwild> </animal> 输出： <animals> <animal type="domestic">cow</animal> <animal

0热度

1回答

没有消费者连接时，卡夫卡经纪人是否可以保留消息？

我正在尝试构建pub/sub应用程序，我正在探索最佳工具。我目前正在寻找卡夫卡并有一个小演示应用程序已经运行。但是，我正在遇到一个概念问题。我有一个制片人（的Java代码）： String topicName = "MyTopic; String key = "MyKey"; Properties props = new Properties(); props.p

2热度

2回答

IBM IIB 9多个数据源

我有消息流与计算节点，这是从数据库调用某些存储过程。我在该节点上为db1设置了数据源字段，在odbc.ini文件中存在相同的名称。现在我需要动态地（不重新部署）将数据源更改为db2。现在我已经找到theese两种解决方案，但他们两人的丑陋：在ODBC.INI和呼叫mqsireload 更改数据源的描述。为分贝名称和模式声明用户定义的属性，并调用这样的存储过程：。 CALL SOME_PROC

3热度

2回答

消费者未在Apache Kafka中收到消息

我正在构建Apache Kafka消费者以订阅另一个已经运行的Kafka。现在，我的问题是，当我的制作人将消息推送到服务器时......我的消费者没有收到它们。这里，我给生产者代码， Properties properties = new Properties(); properties.put("metadata.broker.list","Running kafka ip ad

0热度

1回答

如果消息不会在超时后进入队列，如何处理情况。 Message Broker可能吗？

我想我在标题中描述了几乎所有我需要的东西。所以有一些WMB流量。等待队列中的答案。如果超时后没有队列中的消息，我需要抛出异常。谢谢您的时间

0热度

1回答

如何使用WSO2 ESB中的WSO2 MB

我已经尝试过使用WSO2 Message Broker单独地，它工作得很好。实际上，我创建了两个独立的Java应用程序，它充当发送者和接收者。这两个应用程序都使用amqp连接字符串来启动连接。使用Apache Ant服务器来构建应用程序。现在我想集成Message Broker和WSO2 ESB。建议我使用ESB在我的Web应用程序中使用Message Broker的最佳方式。我会混淆有时