问题标签 [activemq]

为弹簧注入端点给出的示例如下：

如何设置客户端模式端点，以便连接到另一台服务器上的特定端口？

如何配置端点以侦听入站连接？（该示例似乎是一个侦听器，如其描述性 ID 所示，但为什么呢？）

注意：我实际上并没有使用 HL7 协议或编解码器。我将为专有协议编解码器开发自己的。

我已经编译并运行了 ActiveMQ-CPP 2.2.1 Visual Studio 2005 项目。在控制台窗口中，它显示消息正在发送，尽管它们没有被接收。我可以使用 ActiveMQ-CPP 2.0.1 发送和接收消息，但不能使用 2.2.1。我是 ActiveMQ 的新手，甚至不知道从哪里开始进行故障排除。任何想法/建议/开始的好地方都会有很大的帮助。

如果有帮助，我正在使用 ActiveMQ 5.1.0 二进制文件。

提前致谢！

我遇到了ActiveMQ问题，想跟踪/查看所有 ActiveMQ 活动。我能找到的唯一日志文件是与持久数据相关联的（如果打开的话）。我是否查看或生成了任何其他日志文件来告诉我 ActiveMQ 底层发生了什么以及为什么我的消费者不使用消息？还有其他建议吗？

提前致谢！

我正在尝试编译 activemq 附带的示例

在 apache-activemq-5.1.0\example\src\

TopicPublisher.java、CommandLineSupport.java

在通过 netbeans 编译时，它有一些引用问题，说 javax.jms 不存在。

我已经尝试过 j2ee.jar、openjms、sun jms，但它们都给出了相同的错误。

它还抱怨 org.apache.activemq.util 不存在，但我引用的是 activemq-all-5.1.0.jar。

注意：对外部 jar 的所有其他引用都可以正常工作

有任何想法吗？

编辑：需要引用的罐子是

它们在 lib 文件夹中的 activemq 二进制文件中

我正在尝试从 ActiveMQ 开始一个简单的演示，它将演示 TCP 到 TCP 的路由。我在我的 activemq.xml 配置文件中的骆驼上下文中对端点和路由进行编码。

知道为什么这不起作用吗？

AMQ 服务器似乎没有打开监听端口。

编辑：作为一个简单的演示，这里的意图是使用两个 telnet 终端（A 和 B）连接到 ActiveMQ，并能够通过消息队列服务器将消息从一个路由到另一个。稍后，我可能会尝试根据内容进行过滤或路由。

我正在尝试设置一个简单的 activemq 和 mina 演示。我在 activemq.xml 文件中编辑了 camelContext 以包含两个 mina tcp 套接字、两个队列和路由，如下所示：

listenerA -> qA -> listenerB
listenerB -> qB -> listenerA

目的是在两个 telnet 会话之间有两种方式通过。稍后，我将在每个侦听器上添加更多花哨的功能，例如过滤、路由到主题和我自己的编解码器。

这是我的骆驼上下文：

当我启动 activemq 时，我得到一个异常：

org.apache.camel.NoSuchEndpointException：找不到端点：mina:tcp://localhost:42000?textline=true

我是否明确需要添加一个 mina bean？如果是这样，在哪里以及如何？

我使用 Apache.NMS 和 Apcahe.NMS.ActiveMQ（1.0 版）库编写了一个 Windows 服务。该服务使用来自供应商服务器的 ActiveMQ 消息。

该服务启动连接并侦听消息（我处理 OnMessage 事件）

该连接是事务连接，因此我在每条消息后调用 commit。

当服务启动时，一切都运行良好，并且会持续一段时间。但是，它运行一段时间后，将不再消费消息。即使我重置服务。通常需要重新启动我的服务和供应商服务器（tomcat）才能让事情重新开始。供应商坚持认为他们没有任何问题。

任何一方（客户端或服务器）都没有抛出异常 - 它只是“卡住”。

我应该考虑使用 Spring.Messaging.Nms 吗？

我们有一组应用程序，我想使用 JMS 在它们之间进行消息传递。现在，我们的应用程序都与 ActiveMQ 代理建立 TCP 连接。是否可以让同一主机上的 15 个左右的应用程序使用 inVM 连接或使用某种形式的共享内存，而该主机上的其余 20 个左右的应用程序仍然使用 TCP？

基本上，我想将一个配置有 inVM 的代理和一个配置有 TCP 的代理结合起来。我可以这样做，还是必须进行网桥配置？

我的一个程序需要一种可靠的方式来登录不可靠的网络（即互联网）。发送方或接收方可能随时下线，稍后再回来。但是不应错过客户端发送的任何消息。显然 syslog 不符合要求。我正在探索使用像 Apache ActiveMQ 这样的消息服务器而不是 syslog。消息发送者使用 perl、ruby 和 c。所以我有 Stomp 作为消息传输。

这符合我的目的吗？我在这里缺少什么陷阱吗？

拉吉

我正在尝试在 ActiveMQ 上实现性能测试，因此设置了一个基本的生产者和消费者来跨队列发送和接收消息。我创建了一个没有问题的生产者，让它将特定数量的消息写入队列：

这继续完成，没有问题，我已经通过管理网站上的检查确认了这一点，其中有正确数量的待处理消息。

当我尝试从队列中接收消息时会出现问题。使用一个简单的消费者从队列中读取，它将从队列中读取不同数量的消息，但在尝试接收其中一条消息时会停止。我可以看到队列中仍有消息要读取，但客户端不会继续传递其中一条消息。我正在使用一种简单的方法来接收消息：

它适用于一些消息（大约 20-30 条），但随后就会锁定。有人建议我消息中的某些字符可能是转义字符（我使用的是不同长度的随机字符串，因为这只是一个性能测试，实际上并未发送任何内容）所以我更改了所有消息到同一个字符串，这是 char '2' 的重复，仍然没有运气。我正在使用 Spring 配置来加载访问 ActiveMQ 队列所需的所有组件，并且该队列在我的本地主机上运行。