activemq相关内容

在 Apache Karaf 4.0.0.M2 中安装 ActiveMq

我正在尝试在 Karaf 4.0.0M2 中安装 ActiveMQ. 但它总是失败并出现错误.请参阅下面的控制台.请帮我解决这个问题. karaf@root()>功能:安装jmskaraf@root()>功能:repo-add activemq添加功能网址 mvn:org.apache.activemq/activemq-karaf/LATEST/xml/featureskaraf@roo ..
发布时间：2021-11-12 03:48:33 其他开发

尽管代理 URL 为 0.0.0.0，ActiveMQ 远程连接仍被拒绝

我有一个 ActiveMQ v5.7.0 代理，在 Karaf v2.3.3 中运行，我想启用远程连接.我已将代理 URL 设置为 0.0.0.0:61616，以使其能够侦听网络流量.我已经打开防火墙以允许来自客户端计算机的流量.但是，所有远程连接都被拒绝.一个快速的 netstat 似乎告诉我代理没有在本地主机之外监听. jeremy@server:~$ netstat -pan |grep ..
发布时间：2021-11-12 03:48:20 其他开发

ActiveMQ vs Apollo vs Kafka

我以前没有任何使用 *MQ 的经验，我希望在一般情况下建立有关 JMS 和消息队列的知识.这样，我想知道我是应该从 ActiveMQ 开始还是完全“忽略"它并从自学 Apollo 开始.Apollo 和 ActiveMQ 一样功能齐全吗?它是否实现了 JMS 2.0(我看到 ActiveMQ 被 1.1 卡住了)?我会不会遗漏一些非常重要的东西? 另外，Kafka 与这两种解决方案相比如何? ..
发布时间：2021-11-12 02:06:53 其他开发

Apache kafka 与 ActiveMQ 有什么区别

我正在研究 Apache Kafka.我想知道哪个更好:Kafka 或 ActiveMQ.这两种技术的主要区别是什么?我想在 Spring MVC 中实现 Kafka. 解决方案 Kafka 和 ActiveMQ 可能有一些重叠，但它们最初是为不同的目的而设计的.所以比较它们就像比较苹果和橙子一样. 卡夫卡 Kafka 是一个分布式流媒体平台，具有非常好的水平扩展能力.它允许应 ..
发布时间：2021-11-12 01:51:46 其他开发

在骆驼中使用轮询消费者创建持久订阅者

我正在尝试使用轮询消费者创建持久订阅者.URI 是正确的，因为在骆驼路由中使用相同的 uri 并且正确创建了持久订阅者.出于某种原因，PollingConsumer 无法创建持久订阅者，而是创建了普通订阅者. 是否无法使用轮询消费者创建持久订阅者? public class OutQWaitingProcesser 实现 Processor {@覆盖public void process( ..
发布时间：2021-11-11 23:18:12 其他开发

使用来自数据库消息的骆驼启用重播机制

我正在尝试使用骆驼实现重放机制，即，我将不得不检索所有已经持久化的消息并转发到适当的骆驼路由进行重新处理.这将由石英调度程序触发. 我使用下面的方法实现了相同的效果. 1) 一旦石英调度器被触发，转发到处理器，它将查询 db 并将消息作为列表，并在骆驼交换属性中将其设置为列表.2)使用骆驼，其中 LoopProcessor 将在交换中的迭代中设置适当的 xml.3)将它转发到activ ..
发布时间：2021-11-11 23:18:00 其他开发

如何检测 JMS 主题连接丢失

我们有连接到服务器进程的摆动 GUI 客户端. 客户端使用 jms:queue 'from' 在 Camel 路由中定义的端点'调用'服务器上的服务，并使用 ActiveMQ 作为底层 JMS 代理. 但是，客户端还提供了一个 Camel jms:topic 端点，供服务器将消息广播回客户端. 不幸的是，主题连接似乎以某种方式丢失了，尽管客户端仍然可以“调用"服务器上的服务，但服 ..
发布时间：2021-11-11 23:16:43 其他开发

限制侦听 ActiveMQ 队列的所有 JMS 使用者的消耗率

使用 Camel Throttler 组件，您可以定义每个时间段消耗消息的速率上限，例如: from("activemq:queueA").throttle(10).to("direct-vm:bla") 我认为不理想的是，Camel Throttler 将交换保留在内存中，而它们被 Throttler 阻止.因此，如果您有 100 个队列使用者，并且由于任何原因“direct-vm:bla" ..
发布时间：2021-11-11 23:15:23 其他开发

完整的异步 Web 服务通信 - 发送方和接收方无法同时使用

两个系统通过集成(使用 apache-camel)相互通信.假设系统 A 需要向系统 B 提交一个请求，系统 B 已经公开了一个 Web 服务来接收数据，并且集成正在根据系统 B 的 Web 服务转换数据. 在上面的场景中，A 和 B 必须同时可用，A 将不得不等待 B 的响应.我需要通过将队列放在集成层和异步通信来消除这种依赖关系.例如: ..
发布时间：2021-11-11 23:14:51 其他开发

基于时间间隔的节流

我在 ActiveMQ 中有 4 个队列，每个队列中的消息应该发送到外部服务，以便从队列中获取消息，我正在使用 Apache Camel 并且正在限制消息. 但我的问题是对于不同的队列，我有不同的社交时间.例如 队列 1 消息应仅在上午 6 点至下午 5 点之间发送， 队列 2 消息应该只在上午 10 点到晚上 10 点之间发送. 所以我想知道我们如何使用 Apache 骆驼节流来处理 ..
发布时间：2021-11-11 23:13:53 Java开发

控制骆驼路线的启动和关闭

我正在尝试使用骆驼路由为 activemq 队列制作一种轮询服务. 我正在为 grails 使用路由和路由 jsm 插件. 我的路线配置是这样设置的. class QueueRoute {定义配置 = {from("activemq:daemon").routeId("daemonRoute").noAutoStartup().shutdownRunningTask(Shutdown ..
发布时间：2021-11-11 23:13:32 其他开发

ExchangePattern.InOnly 对 mq 端点的影响

我的路线定义为 from("jetty:http://0.0.0.0:xxxx/abc").to("activemq:queue:queue1").setExchangePattern(ExchangePattern.InOnly); 我了解此路由会向代理发送消息，并且不会等待消息消费者使用它.我想了解 ExchangePattern.InOnly 对代理接受消息的影响.我在代理上启用了持久性 ..
发布时间：2021-11-11 23:11:43 其他开发

ExchangePattern.InOnly 对 mq 端点的影响

我的路线定义为 from("jetty:http://0.0.0.0:xxxx/abc").to("activemq:queue:queue1").setExchangePattern(ExchangePattern.InOnly); 我了解此路由会向代理发送消息，并且不会等待消息消费者使用它.我想了解 ExchangePattern.InOnly 对代理接受消息的影响.我在代理上启用了持久性 ..
发布时间：2021-11-11 23:07:23 其他开发

Camel 应用程序在关闭会话后尝试使用 JMS 会话

我是骆驼的新手，我正在尝试在 JBoss EAP 7 上编写一个桥接 Websphere MQ 和 Active MQ 的应用程序.该应用程序部署成功运行，我可以在 Websphere 队列上放置消息，并且它被 Active 接收MQ.但是，我在日志中看到错误消息，显示它在打开后尝试使用连接. 15:48:57,814 错误 [org.jboss.jca.core.connectionmanag ..
发布时间：2021-11-11 23:05:55 其他开发