-
2 votesanswersviews
查看队列使用者时出错
导航到Active MQ管理控制台然后:队列 - >活动消费者(一个's I' m尝试名称前缀为私有:)我得到: 处理此请求时发生异常,请检查日志以获取更多信息! 从日志中提取: ==> activemq.log <== 2017-06-29 08:22:06,564 |警告| | org.eclipse.jetty.servlet.ServletHandler | qtp... -
4 votesanswersviews
如何使用Spring Boot配置嵌入式ActiveMQ Broker URL
我按照一个简单的例子来设置和运行带有Spring Boot的嵌入式ActiveMQ(版本1.4.X) . 这是示例https://spring.io/guides/gs/messaging-jms/的链接 我的课程结构如下: @SpringBootApplication @EnableJms public class Application { @Autowired ConfigurableAp... -
0 votesanswersviews
使用RabbitMQ订阅一组消费者?
我不完全确定这是正确的问题,但我对RabbitMQ实现发布/订阅消息传递系统的功能有疑问 . 我正在调查RabbitMQ,看它是否符合我工作的公司的需求,我在官方文档或互联网上找不到这些问题的答案: 消费者是否可以订阅一组发布者?我想这是可能的,如果我们想要订阅的所有发布者都将他们的消息发送到交换机,然后将它们转发给订户 . 实现这个最合适的呼出类型是什么? 是否可以订阅一组主题?例如,如... -
2 votesanswersviews
kafka多经纪人的优势
嗨,我对apache kafka很新,我不知道这会有多大意义 . 我做了很多研究,但却找不到多个经纪人的优势 . 通过整个kafka文档,无法找到答案 . 比方说,我从两个不同的设备接收数据,我应该操作和存储 . 根据从哪个设备数据到达,消费者将改变 . 我应该使用多个代理 - 单个主题 - 多分区或单个代理 - 单个主题 - 多分区或其他一些方法? 任何帮助或指南表示赞赏 . -
3 votesanswersviews
消费者没有在Apache Kafka中收到消息
我正在构建一个Apache Kafka消费者来订阅另一个已经运行的Kafka . 现在,我的问题是当我的制作人将消息推送到服务器时...我的消费者没有收到它们 . Here I give Producer code, Properties properties = new Properties(); properties.put("metadata.broker.li... -
0 votesanswersviews
AMQP QPID中的网络流量
QPID AMQP 我有一个问题重新调整网络流量 . 假设我在机器A上有一个发布者 . Qpid代理正在机器B上运行 . 我们有两个订户机器C和机器D(他们都订阅相同的主题) . 现在想象一下拓扑在哪里A - > B - > X - > C | D(发布者A连接到B,订阅者C和D连接到Broker通过和中间节点X)A发布的消息与C和D的主题相匹配将被两者接收 . 我想知道... -
0 votesanswersviews
在activemq 5.8中配置纯主/从配置时出错?
我正在尝试配置纯主/从代理配置 . 在slave activemq.xml文件中,我有以下配置 <services> <masterConnector remoteURI="tcp://localhost:61616" /> </services> 当我启动奴隶经纪人时它会给我以下错误: 加载失败:类路径资源[activemq.x... -
0 votesanswersviews
如何使用JMeter测试WSO2 Message Broker
我在使用JMS Publisher让JMeter与WSO2 Message Broker一起工作时遇到了一些问题 . 我让JMeter与ActiveMQ合作,但我仍然使用该工具 . 我将客户端库复制到jmeter wso2mb-2.0.1 \ client-lib到apache-jmeter-2.9 \ lib andes-client-0.13.wso2v4.jar geronimo-j... -
3 votesanswersviews
如何在kubernetes上为Kafka多代理设置指定广告监听器并在经验上公开集群?
我正在尝试在Azure中托管的kubernetes集群上设置多代理kafka . 我有一个代理设置工作 . 对于多代理设置,目前我有一个管理kafka服务的zookeeper节点集合(3) . 我正在将kafka集群部署为复制控制器,复制因子为3.这是3个代理 . 如何向Zookeeper注册这三个代理,以便它们与Zookeeper注册不同的IP地址? 部署服务后,我会调出复制控制器,并在复制控制... -
0 votesanswersviews
MassTransit通用消费者不消费
我正在和RabbitMQ一起使用MassTransit 3 . 我在网站上更改了经典示例: 这个: x.ReceiveEndpoint(host, ConfigurationManager.AppSettings["ServiceQueueName"], e => { e.Consumer<RequestConsumer>(); }); 同 var ... -
1 votesanswersviews
如何将RocketMQ代理与RocketMQ控制台连接以获取详细信息?
我是Apache RocketMQ的新手 . 我发现我们可以使用RocketMQ控制台来获取RocketMQ消息事务的详细信息 . see here 如何将该控制台与我本地运行的RockerMQ代理连接(同步)? 我正在使用this documentation来运行代理和客户端 . -
0 votesanswersviews
不同机器上的Kafka MultiBroker无法正常工作
我正在实施一个Kafka集群架构,在两台本地连接的机器上有2个经纪人和2个动物园管理员 Machine1(10.0.215.22):( Hidding trival属性)Kakfa - > Server.properties port=9094 broker.id=1 num.partitions=1 zookeeper.connect=10.0.215.22:2181,10.0.229.... -
1 votesanswersviews
消息队列和消息代理差异
所以我一直试图了解消息队列和消息代理之间的区别,为什么要使用其中一个 . 所以从我的理解 . MESSAGE QUEUE有助于进程间通信,但它基本上只限于允许2个应用程序之间的通信?我问这个是因为例如MSMQ(如果我的理解是正确的)只将消息存储在队列中,直到第一个消费者处理它,之后它会自动将它从队列中删除 . 它是否正确 ? 现在MESSAGE BROKERS是MESSAGE QUEUE的某种延... -
2 votesanswersviews
如何在故障转移方案中通过Active-MQ Broker传递相同的Java应用程序?
有两个名为 GC1 和 GC2 的客户端使用主题“ GC1Alive " & " GC2Alive ”通过ActiveMQ相互通信 . 他们只是通过使用这些主题发送心跳 . Purpose 两个GC之间通信的目的是当 GC1 发生故障时, GC2 应该在故障转移场景中替换 GC1's 位置 . 故障转移方案由ActiveMQ自行处理,其中包含以下URL: URL =... -
2 votesanswersviews
从IBM Message Broker获取间歇性BIP3113E错误
我在Message Broker中部署了一个消息流 . 该流调用后端Web服务 . Broker已将已部署的流作为WSDL发布 . 我使用了WSDL并使用Maven创建了一个测试客户端 . 客户工作和一切 . 我可以调用流程并获得结果 . 只有大约一半的电话是成功的,有一半的时间我得到了这个: 有没有人遇到过这个?谢谢 javax.xml.ws.soap.SOAPFaultException:... -
0 votesanswersviews
从IBM Message Broker迁移到Apache Camel
我的客户希望从IBM产品迁移到opensource . 目前,解决方案正在IBM Message broker v6.1和WAS v6中运行 . 我们可以将Message flow v6.1迁移到Apache Camel吗?如果是,那么步骤以及如何设计计划将是什么? 谢谢,Harshita -
0 votesanswersviews
芹菜 Worker 死了,但经纪人联系活着
我一直致力于一个应用程序,其基础结构如下所示 - 我们正在使用AWS进行部署 . 1个EC2实例 - 我的经纪人(rabbitmq服务器)正在这里运行 芹菜工作者在Auto Scaling Group(ASG)实例上运行 . 问题 - 工作者与代理 Build 连接 . 一旦工作人员完成其职责,ASG实例(工作人员实例)就会死亡,但在EC2实例中,rabbitmq连接仍处于“运行”状态 . 这些连... -
1 votesanswersviews
Fiware Orion:如何根据属性值删除实体
我在Orion上下文代理中有许多实体,如下所示 . user_id属性用于区分由不同用户生成的实体 . { "_id": { "id": "customCommands", "type": "Command", "servicePa...