我创建了下面的active emq代理配置并尝试在servicemix 5.3.0中安装。
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:broker="http://activemq.apache.org/schema/core"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" />
<broker:broker brokerName="myBroker1" dataDirectory="${karaf.data}/activemq/myBroker1"
useShutdownHook="false" startAsync="true">
<broker:destinations>
<broker:queue physicalName="SOME.QUEUE" />
</broker:destinations>
<!-- The transport connectors ActiveMQ will listen to -->
<broker:transportConnectors>
<broker:transportConnector name="openwire" uri="tcp://localhost:61617" />
<broker:transportConnector name="stomp" uri="stomp://localhost:61614" />
</broker:transportConnectors>
</broker:broker>
</beans>
我在servicemix 5.3.0日志中发现以下错误
经纪人还没有开始。请帮忙。谢谢
我们目前在ServiceMix 5.3. x和5.4. x中存在一个问题,在Karaf 2.4. x(https://issues.apache.org/jira/browse/SM-2414)中缺少Spring Deployer。
作为一种解决方法,您可以在ServiceMix 5.3.0上手动安装它
osgi:install -s mvn:org.apache.karaf.deployer/org.apache.karaf.deployer.spring/2.4.0
以及5.3.1和5.4.0:
osgi:install -s mvn:org.apache.karaf.deployer/org.apache.karaf.deployer.spring/2.4.1
我希望有帮助。
我找到了不是专门针对错误的问题的解决方案。我使用了蓝图及其工作正常。下面是蓝图代理配置
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
xmlns:ext="http://aries.apache.org/blueprint/xmlns/blueprint-ext/v1.0.0"
xmlns:broker="http://activemq.apache.org/schema/core">
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" />
<broker:broker brokerName="myBroker1"
dataDirectory="${karaf.data}/activemq/myBroker1" useShutdownHook="false"
startAsync="true">
<broker:destinations>
<broker:queue physicalName="SOME.QUEUE" />
</broker:destinations>
<broker:transportConnectors>
<broker:transportConnector name="openwire"
uri="tcp://localhost:61617" />
<broker:transportConnector name="stomp"
uri="stomp://localhost:61614" />
</broker:transportConnectors>
</broker:broker> </blueprint>
我在完整图形拓扑上有一个代理网络,在不同服务器上有3个节点:A,B和C。每个代理都附加了一个生产者,并且出于测试目的,在代理 C 上只有一个非代理使用者。由于我使用的是完整图拓扑,因此每个代理还为其他每个节点都有一个代理使用者。 问题是:A收到一些消息。我希望它将这些消息转发给代理C,该代理连接了一个“真实”消费者。这不会发生,代理A存储这些消息,直到一个“真实”消费者连接到它。 我的配置(或理解
我在集群的ubuntu节点上设置了一个kafka 0.11.0.0实例。直到几周前,一切都正常工作,今天我尝试启动它,在启动后出现以下错误: 我的服务器。特性: 我编辑了广告。侦听器,因为存在将请求重定向到代理的代理。无论如何,直到几周前一切都很好。。。 我开始Kafka的步骤: 有什么建议吗?谢谢你们
从服务器1的web控制台创建的消息在服务器2的web控制台中不可见。这种配置有什么问题? web控制台中的状态:
我正试图找到一种方法,将请求负载平衡到一组相似配置的activemq代理。假设,我有3个activemq代理(A,B,C),每个代理都有两个队列(X,Y)在运行。 每个活动 mq 代理都有相同的队列,即。X 现在,我想对我的3个队列的负载平衡请求进行循环负载平衡。即第一个请求应该去队列A,然后下一个请求去队列B,然后下一个请求去队列C,依此类推。 请指导。
问题内容: 编辑:改写问题: 我想将ActiveMQ用作服务器和客户端应用程序之间的信使服务。 我正在尝试在服务器内设置嵌入式代理(即不是单独的进程),以处理产生的消息供我的客户使用。该队列被保留。 经纪人初始化如下: 修补之后,我最终得到了服务器部分: 客户端非常相似,看起来像这样: main方法只是在线程中启动其中的每一个,以开始生成/接收消息。 …但是我在每个线程的开头都遇到以下问题: 看来
我正在尝试设置一个支持SSL的嵌入式ActiveMQ代理。 我不断得到相同的错误msg: 搜索这给出了在生成密钥存储和信任存储时可能发生故障的指示。 我试图使用这些指南生成密钥存储和信任存储,但没有成功。http://docs.oracle.com/javase/6/docs/technotes/guides/security/jsse/JSSERefGuide.html#CreateKeysto