activemq 相关问题

Apache ActiveMQ是一个开源(Apache 2.0许可)消息代理,它完全实现了Java Message Service 1.1(JMS)。它提供了“企业功能”,如群集,多个消息存储,以及将任何数据库用作除VM,缓存和日志持久性之外的JMS持久性提供程序的能力。

ActiveMQ:单个生产者,多个消费者

我有一个使用ActiveMQ的消息队列。 Web请求将消息以persistency = True放入队列。现在,我有两个使用者,它们分别作为单独的会话连接到此队列。消费者1 ...

回答 1 投票 0

在Lua中具有自定义属性的STOMP

发布主题消息时,我试图在STOMP消息头中放入两个自定义属性,以便订阅者可以过滤消息。这是我发送的两个帧,用于连接并发布到...

回答 1 投票 0

当消息在ActiveMQ中入队和出队时如何编写自定义日志

[当我入队/出队消息时,ActiveMQ在 / data / activemq.log 2020-03-03 12:59:36,505 | test001 |调试| queue:// test001,subscriptions = 0,内存= 0%,...

回答 1 投票 2

SqlServer触发器可以推送到ActiveMQ

谁能告诉我是否有可能将数据从SqlServer触发器直接推送到ActiveMQ。我搜寻了ActiveMQ文档,但没有看到任何参考。我们可以使用服务...

回答 2 投票 2

在ActiveMQ中发布者入队消息和使用者出队消息时如何编写自定义日志

我有两个示例C#应用程序。 ActiveMQPublisher:var connectUri = new Uri(“ activemq:tcp:// hos1:61616”); var factory = new NMSConnectionFactory(connectUri);使用(var connection = factory ....

回答 1 投票 2

将Java POJO转换为JSON,反之亦然,因为使用Jackson的ActiveMQ上不支持的有效负载而产生错误

我的应用程序通过UI接收一些数据并进入ActiveMQ。另一个服务侦听消息队列中的消息。我收到类似这样的错误:无法转换类型[com.ibm.www ....

回答 2 投票 1

NodeJS rhea AMQP客户端的故障转移

我在计算机上运行了多个ActiveMQ实例。它们被配置为共享文件系统主从。如果一台ActiveMQ服务器已关闭,则另一台应自动启动。 ...

回答 1 投票 0

ActiveMQ:如何将同一组消息发送到一个使用者线程

我们在我们的项目中使用ActiveMQ,我们要求属于一个组的一组消息应由一个使用者线程使用。例如,我们有3条(M1,M2,M3)消息...

回答 1 投票 0

ActiveMQ:如何对具有自定义属性的队列中的消息重新排序

我们正在项目中使用ActiveMQ,并且各种生产者将消息同时写入到ActiveMQ中。因此,订购混乱了。无论如何,消息是否可以...

回答 1 投票 0

使用骆驼从Active MQ Queue1到Queue2的路由消息保持不变

[当我使用来自Queue1的AMQ消息并将其发送到Queue2时,已落入队列2的消息具有:1)现在,原始消息中的messageId填充在面包屑ID头中。 ...

回答 1 投票 0

[CORDA区块链与elasticsearch或ActiveMQ集成

我是CORDA区块链的新手,我想知道在像Elasticsearch或Cassandra这样的NoSQL DB中存储Corda状态/保管库的可能性。还是可以将保管库数据放入ActiveMQ?

回答 1 投票 0


使用Stomp协议连接到ActiveMQ的Python程序不断断开连接

下面是python程序中用于连接到ActiveMQ的连接参数broker_url = config_params.items('BROKERS')conn = stomp.Connection12(broker_url,...

回答 2 投票 0

Log4j JMS附加程序将空消息发送到STOMP客户端

Am使用log4j JMS附加程序转发日志消息。并且正在使用STOMP-CLIENT运行Node JS,以侦听activemq,以接收转发的日志消息。现在的问题是,每当日志为...

回答 1 投票 2

Exchange邮件标题格式

我正在尝试设置交换消息头。在格式化代码时需要帮助。我需要在标题usr.Person.Name =“ Peter” usr.Person.ID =“ ABC123”中设置以下值,我尝试了exchange.getIn()....

回答 2 投票 0

一旦启动active-mq代理,是否可以创建virtualDestinations和CompositeQueue?

请考虑以下情形:假设有4个微服务,每个微服务应该具有自己的队列。让我们使用以下场景微服务A->队列。微服务B ...

回答 1 投票 0

Java JMS-消息侦听器和onException

我有一个带有主线程和JMS线程的应用程序,它们通过ActiveMQ 5.15.11相互通信。我可以发送消息,但是我想要一种发送状态或...

回答 1 投票 0

如何找到cron的ActiveMQ计划时间

我们正在使用ActiveMQ预定消息功能来触发事件并按时处理。如果cron计划在每天的00:00:00进行,则该事件的brokerInTime类似于00:01:00。这是...

回答 1 投票 0

如何在Qpid JMS中为ActiveMQ(如RabbitMQ)创建主题交换?

我有一个使用RabbitMQ的Java应用程序。该应用程序创建一个TOPIC交换,并使用其自己的路由密钥将消息推送到TOPIC。通过这种方式,如果我想要来自任何...的数据...

回答 1 投票 0

是否可以从IDestination检索队列/主题名称?

我可以从收到的IMessage.NMSReplyTo中获取IDestination。但我想查看其名称(用于记录)。有办法吗?

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.