Tag: activemq

ActiveMQ主题通配符不起作用

我想了解如何正确填充主题的authorizationEntry条目。 我已阅读了此页面上的详细信息[通配符语法] [1] ActiveMQ 5.14.3作为Docker容器运行 截至目前,我已经设置了以下用户(cpe = client,co = server) <simpleAuthenticationPlugin> <users> <authenticationUser username="system" password="manager" groups="co,cpe,admins"/> <authenticationUser username="wbhms" password="password" groups="co"/> <authenticationUser username="kpi" password="password" groups="co"/> <authenticationUser username="cpeuser" password="password" groups="cpe"/> </users> </simpleAuthenticationPlugin> 我的授权插件定义如下,以决定谁可以读写每个主题。 这些主题都以识别客户端设备的string为前缀。 因此,对于主题为kpi.lte.gzipjson的设备000295-0123456789 ,完整主题名称为000295-0123456789.kpi.lte.gzipjson 。 所以我的想法是在主题属性前添加一个*,如下图所示,以说明所有设备。 <authorizationPlugin> <map> <authorizationMap> <authorizationEntries> <authorizationEntry topic=">" read="admins,co,cpe" write="admins,co,cpe" admin="admins,co,cpe"/> <authorizationEntry topic="*.will.json>" read="co" write="cpe" admin="admins,cpe"/> <authorizationEntry topic="*.kpi.lte.gzipjson>" read="co" write="cpe" admin="admins,cpe"/> […]

Docker用户定义的networking – 通过容器主机名称的容器间通信

问题 – Spring-Boot消息监听器Docker Container无法连接到同一个Docker用户定义的networking中的ActiveMQ Docker容器 configurationSpring-Boot Message Listener来检查“ activemq.hostname ” <bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="failover: (tcp://${activemq.hostname:0.0.0.0}:61616)?randomize=false" /> </bean> 为Spring-Boot Message Listener创buildDocker文件 – 将消息代理的主机名设置为事件代理 FROM openjdk:8-jdk-alpine EXPOSE 9001 RUN mkdir /app/ COPY target/event-ingestion-router-1.0.2.jar /app/ ENTRYPOINT exec java $JAVA_OPTS -Dactivemq.hostname='event-broker' -jar /app/event-ingestion-router-1.0.2.jar 创buildDockernetworking docker network create –driver=bridge messaging-network 使用主机名事件代理创build在“消息传递networking”上运行的ActiveMQ 代理 docker run -d -p 61616:61616 -p […]

keystore格式问题 – 作为docker容器的骆驼项目

我正在创build一个camel项目的docker container 。 我从这里创build了密钥库文件。 这些密钥库文件放在servicemix > etc文件夹中。 现在,当我正常运行骆驼项目它正常运行。 现在,当我为camel项目创buildDocker容器时,我已经移动了src > main > resources的keystore文件夹,并在camelcontext.xml使用了 – <property name="maxConnections" value="10" /> <property name="connectionFactory"> <bean class="org.apache.activemq.ActiveMQSslConnectionFactory"> <property name="brokerURL" value="${karaf-local.url}" /> <property name="userName" value="${karaf-local.userName}" /> <property name="password" value="${karaf-local.passwordEncrypted}" /> <property name="keyStore" value="keystores/client.ks" /> <property name="keyStorePassword" value="${keyStorePassword}" /> <property name="trustStore" value="keystores/client.ts" /> <property name="trustStorePassword" value="${trustStorePassword}" /> </bean> </property> 其他值来自我的configuration文件。 但是,当我使用docker run命令创build容器时,我得到错误 […]

docker hub上的apache / activemq docker镜像

我正在寻找docker中心的官方docker图像的ActiveMQ https://github.com/apache/activemq任何人都可以指向我在docker集线器https://hub.docker.com/

连接到在Docker容器上运行的远程activemq实例

我有2个docker集装箱,一个运行一个spring的应用程序(在tomcat中),一个运行一个活动的mq实例。 当我尝试从我的spring的应用程序连接到它,我得到以下错误。 只有activeMQ在一个容器上运行,并且端口已经正确显示。 我validation了docker集装箱的IP地址(如下所示),这是正确的。 我不确定在这一点上可能会导致这个错误。 任何想法将不胜感激。 错误[activemq.broker.BrokerService]启动Apache ActiveMQ失败([mybroker,ID:489af431756c-60313-1409695404227-0:1],java.io.IOException:传输连接器无法在JMX中注册:无法绑定到服务器socket:tcp://172.17.0.2:61616?maximumConnections = 1000&wireFormat.maxFrameSize = 104857600由于:java.net.BindException:无法分配请求的地址)

使用Core API连接到ActiveMQ Artemis Docker容器

我正在尝试使用ActiveMQ Artemis Core API连接到Docker容器中运行的ActiveMQ Artemis。 我正在使用下面的代码来尝试连接。 Map<String,Object> connectionParams = new HashMap<String, Object>(); connectionParams.put(TransportConstants.PORT_PROP_NAME, "61616"); connectionParams.put(TransportConstants.HOST_PROP_NAME, "localhost"); TransportConfiguration tc = new TransportConfiguration(NettyConnectorFactory.class.getName(),connectionParams); ServerLocator locator = ActiveMQClient.createServerLocatorWithoutHA(tc); ClientSessionFactory queueFactory = locator.createSessionFactory(); 运行时,当我尝试创build会话工厂时,出现以下错误。 ActiveMQNotConnectedException[errorType=NOT_CONNECTED message=AMQ119007: Cannot connect to server(s). Tried with all available servers.] 在尝试连接到ActiveMQ Artemis代理时,似乎是缺less一个关键的configuration步骤。 有一个XML文件,我需要放置在我的Java客户端应用程序的某个地方,或者我可以在代码中设置适当的设置? AtiveMQ Artemis的Docker镜像我正在使用: https://github.com/vromero/activemq-artemis-docker

如何将docker上的spring应用程序连接到docker上的activemq集群

我有一个简单的REST应用程序在Docker容器中的Tomcat8上运行。 我也有3个docker容器,分别在端口61617和61618 master slave上运行ActiveMQ 5.11.1代理(使用mysql作为持久化)。 docker run –name myRESTApp -t -i –rm -p 8080:8080 -p 9090:9090 -v $(pwd)/webapps:/usr/local/tomcat/webapps -v $(pwd)/logs:/usr/local/tomcat/logs –link activemq1:activemq myRESTApp 在myRESTApp的activeMQConfiguration.xml : <property name="brokerURL" value="failover:(#{systemEnvironment['ACTIVEMQ_PORT_61616_TCP']})?randomize=false"/> 3个ActiveMQ代理在他们的activemq.xml有这个: <transportConnectors> <transportConnector name="openwire" uri="tcp://0.0.0.0:0" updateClusterClients="true" rebalanceClusterClients="true" updateClusterClientsOnRemove="true" /> </transportConnectors> 主人最初是在61616运行,我停止了主人,奴隶(港口61617 )成为新的主人。 甚至在61616的主人被停止之前,它就投掷了 Connect fail to: tcp://172.17.0.84:61616, reason: java.net.ConnectException: Connection refused 为什么链接后,它仍然无法连接到经纪人? 在61616上的主站停止后,将失败: Connect fail to: tcp://172.17.0.84:61616, […]

与ActiveMQ链接的Docker Tomcat

我需要一个托pipeTomcat和ActiveMQ的容器。 我设法使用supervisord来做到这一点,容器完美地工作。 但是后来我认为这个概念是不好的,因为我在Tomcat中部署一场新的战争时,我不想失去我的主动MQ信息。 所以我做了2个容器并连接它们,一个用于activemq,一个用于tomcat。 我可以看到,tomcat链接到activemq,但在tomcat中部署的战争对activeMQ没有任何作用。 我的问题是:任何提示我怎么才能检查他们为什么不沟通,即使容器链接,创build环境等? 另外如果有人可以链接一个git的中心仓库,其中有人正在使用tomcat和activemq链接2个不同的容器? 另外,如果你们中的一些人知道一个很好的做法bloog,与docker中activemq的使用有关,那么当重新创build容器时,我担心丢失的消息。 从我的angular度来看,docker集装箱是应该能够以完全相同的状态从图像构build的东西。 使用活动的MQ这有点棘手,我不知道activemq在磁盘上保存消息的位置,以及如果共享卷将修复docker的持久性问题。 另一方面,你通常不会重新部署一个带有activemq的容器,但是如果发生这种情况,主机重启( – >销毁所有的容器),那么安全措施是什么?

JBoss Fuse,使用ActiveMQ创build容器

我们正在使用JBoss Fuse 6.2(在Docker中,但在这里已经被淘汰了)。 我们正在用命令创build一个容器: bin/admin create $containername 我们有两种情况:我们使用以下命令启动容器: /bin/admin start $containername 这样,activemq根本不被激活。 另一种情况是启动没有参数的容器: ./bin/start 这样,容器将激活ActiveMq。 请帮我理解行为:如果以bin / start启动,相同的创build的容器将激活ActiveMQ,但如果以bin / admin / start $ containername启动,将不会激活它。 旁边的问题:当创build一个容器与斌/pipe理员/创build,activemq默认安装或不? 提前致谢。

用activemq添加camunda -bpm-wildfly并运行在相同的docker容器中

我想添加与活动mq camunda-bpm-wildfly并运行在相同的docker容器中。 首先,我将它们添加到两个容器,并尝试运行如下。 还可以。 1.运行camunda-bpm-wildfly。 Dockerfile: FROM camunda/camunda-bpm-platform:wildfly-latest ADD standalone.xml standalone/configuration/ ADD bin/ bin/ ADD fusepatch/ fusepatch/ ADD modules/ modules/ ADD hawtio-wildfly-1.5.3.war standalone/deployments/ 命令: docker build my-wildfly . docker images sudo docker run -d –name my-wildfly –net="host" -p 7070:7070 my-wildfly 2.运行activemq。 Dockerfile: FROM webcenter/activemq:latest 命令: docker build amq-alone . docker images docker run –name='amq-alone' -d […]