Apologies! Preview was working but... don't know what happened.
Java client application exception:
Caught exception! javax.jms.JMSException: AMQ219014: Timed out after waiting
30,000 ms for response when sending packet 71
javax.jms.JMSException: AMQ219014: Timed out after waiting 30,000 ms for
response when sending packet 71
at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:454)
at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:358)
at
org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.sendFullMessage(ActiveMQSessionContext.java:554)
at
org.apache.activemq.artemis.core.client.impl.ClientProducerImpl.sendRegularMessage(ClientProducerImpl.java:303)
at
org.apache.activemq.artemis.core.client.impl.ClientProducerImpl.doSend(ClientProducerImpl.java:275)
at
org.apache.activemq.artemis.core.client.impl.ClientProducerImpl.send(ClientProducerImpl.java:128)
at
org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.doSendx(ActiveMQMessageProducer.java:485)
at
org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:195)
at
com.activemq.test.perf.artemis.producer.ArtemisProducer.run(ArtemisProducer.java:39)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source)
at java.lang.Thread.run(Unknown Source)
Caused by: ActiveMQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT
message=AMQ219014: Timed out after waiting 30,000 ms for response when
sending packet 71]
... 12 more
...
Here the conf of the first broker: artemis-1M
<?xml version='1.0'?>
<configuration xmlns="urn:activemq"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:xi="http://www.w3.org/2001/XInclude";
xsi:schemaLocation="urn:activemq
/schema/artemis-configuration.xsd">
<core xmlns="urn:activemq:core"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="urn:activemq:core ">
<name>artemis-1M</name>
<persistence-enabled>true</persistence-enabled>
<journal-type>ASYNCIO</journal-type>
<paging-directory>vagrant_data/data/paging</paging-directory>
<bindings-directory>vagrant_data/data/bindings</bindings-directory>
<journal-directory>vagrant_data/data/journal</journal-directory>
<large-messages-directory>vagrant_data/data/large-messages</large-messages-directory>
<journal-datasync>true</journal-datasync>
<journal-min-files>2</journal-min-files>
<journal-pool-files>10</journal-pool-files>
<journal-file-size>10M</journal-file-size>
<journal-buffer-timeout>16000</journal-buffer-timeout>
<journal-max-io>4096</journal-max-io>
<disk-scan-period>5000</disk-scan-period>
<max-disk-usage>90</max-disk-usage>
<critical-analyzer>true</critical-analyzer>
<critical-analyzer-timeout>120000</critical-analyzer-timeout>
<critical-analyzer-check-period>60000</critical-analyzer-check-period>
<critical-analyzer-policy>HALT</critical-analyzer-policy>
<ha-policy>
<shared-store>
<master>
<failover-on-shutdown>true</failover-on-shutdown>
</master>
</shared-store>
</ha-policy>
<cluster-user>ACTIVEMQ.CLUSTER.ADMIN.USER</cluster-user>
<cluster-password>XxXxX</cluster-password>
<cluster-connections>
<cluster-connection name="artemis-cluster">
<address>jms</address>
<connector-ref>artemis-1M</connector-ref>
<check-period>1000</check-period>
<connection-ttl>5000</connection-ttl>
<min-large-message-size>50000</min-large-message-size>
<call-timeout>5000</call-timeout>
<retry-interval>500</retry-interval>
<retry-interval-multiplier>1.0</retry-interval-multiplier>
<max-retry-interval>5000</max-retry-interval>
<initial-connect-attempts>-1</initial-connect-attempts>
<reconnect-attempts>-1</reconnect-attempts>
<use-duplicate-detection>true</use-duplicate-detection>
<message-load-balancing>ON_DEMAND</message-load-balancing>
<max-hops>1</max-hops>
<confirmation-window-size>32000</confirmation-window-size>
<call-failover-timeout>30000</call-failover-timeout>
<notification-interval>1000</notification-interval>
<notification-attempts>2</notification-attempts>
<static-connectors allow-direct-connections-only="true">
<connector-ref>artemis-1S</connector-ref>
</static-connectors>
</cluster-connection>
</cluster-connections>
<connectors>
<connector name="artemis-1M">tcp://artemis-1M:61616</connector>
<connector name="artemis-1S">tcp://artemis-1S:61616</connector>
</connectors>
<acceptors>
<acceptor name="artemis">tcp://0.0.0.0:61616</acceptor>
</acceptors>
<security-settings>
<security-setting match="#">
<permission type="createNonDurableQueue" roles="amq"/>
<permission type="deleteNonDurableQueue" roles="amq"/>
<permission type="createDurableQueue" roles="amq"/>
<permission type="deleteDurableQueue" roles="amq"/>
<permission type="createAddress" roles="amq"/>
<permission type="deleteAddress" roles="amq"/>
<permission type="consume" roles="amq"/>
<permission type="browse" roles="amq"/>
<permission type="send" roles="amq"/>
<permission type="manage" roles="amq"/>
</security-setting>
</security-settings>
<address-settings>
<address-setting match="activemq.management#">
<dead-letter-address>DLQ</dead-letter-address>
<expiry-address>ExpiryQueue</expiry-address>
<redelivery-delay>0</redelivery-delay>
<max-size-bytes>-1</max-size-bytes>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<address-full-policy>PAGE</address-full-policy>
<auto-create-queues>true</auto-create-queues>
<auto-create-addresses>true</auto-create-addresses>
<auto-create-jms-queues>true</auto-create-jms-queues>
<auto-create-jms-topics>true</auto-create-jms-topics>
</address-setting>
<address-setting match="#">
<dead-letter-address>DLQ</dead-letter-address>
<expiry-address>ExpiryQueue</expiry-address>
<redelivery-delay>0</redelivery-delay>
<max-size-bytes>-1</max-size-bytes>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<address-full-policy>PAGE</address-full-policy>
<auto-create-queues>true</auto-create-queues>
<auto-create-addresses>true</auto-create-addresses>
<auto-create-jms-queues>true</auto-create-jms-queues>
<auto-create-jms-topics>true</auto-create-jms-topics>
</address-setting>
<address-setting match="jms.#">
<redistribution-delay>1000</redistribution-delay>
</address-setting>
</address-settings>
<addresses>
<address name="DLQ">
<anycast>
<queue name="DLQ" />
</anycast>
</address>
<address name="ExpiryQueue">
<anycast>
<queue name="ExpiryQueue" />
</anycast>
</address>
</addresses>
<broker-plugins>
<broker-plugin
class-name="org.apache.activemq.artemis.core.server.plugin.impl.LoggingActiveMQServerPlugin">
<property key="LOG_ALL_EVENTS" value="false"/>
<property key="LOG_CONNECTION_EVENTS" value="true"/>
<property key="LOG_SESSION_EVENTS" value="true"/>
<property key="LOG_CONSUMER_EVENTS" value="false"/>
<property key="LOG_DELIVERING_EVENTS" value="false"/>
<property key="LOG_SENDING_EVENTS" value="false"/>
<property key="LOG_INTERNAL_EVENTS" value="true"/>
</broker-plugin>
</broker-plugins>
</core>
</configuration>
...
Here the conf of the second broker: artemis-1S
<?xml version='1.0'?>
<configuration xmlns="urn:activemq"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:xi="http://www.w3.org/2001/XInclude";
xsi:schemaLocation="urn:activemq
/schema/artemis-configuration.xsd">
<core xmlns="urn:activemq:core"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="urn:activemq:core ">
<name>artemis-1M</name>
<persistence-enabled>true</persistence-enabled>
<journal-type>ASYNCIO</journal-type>
<paging-directory>vagrant_data/data/paging</paging-directory>
<bindings-directory>vagrant_data/data/bindings</bindings-directory>
<journal-directory>vagrant_data/data/journal</journal-directory>
<large-messages-directory>vagrant_data/data/large-messages</large-messages-directory>
<journal-datasync>true</journal-datasync>
<journal-min-files>2</journal-min-files>
<journal-pool-files>10</journal-pool-files>
<journal-file-size>10M</journal-file-size>
<journal-buffer-timeout>16000</journal-buffer-timeout>
<journal-max-io>4096</journal-max-io>
<disk-scan-period>5000</disk-scan-period>
<max-disk-usage>90</max-disk-usage>
<critical-analyzer>true</critical-analyzer>
<critical-analyzer-timeout>120000</critical-analyzer-timeout>
<critical-analyzer-check-period>60000</critical-analyzer-check-period>
<critical-analyzer-policy>HALT</critical-analyzer-policy>
<ha-policy>
<shared-store>
<slave>
<failover-on-shutdown>true</failover-on-shutdown>
<allow-failback>true</allow-failback>
</slave>
</shared-store>
</ha-policy>
<cluster-user>ACTIVEMQ.CLUSTER.ADMIN.USER</cluster-user>
<cluster-password>XxXxX</cluster-password>
<cluster-connections>
<cluster-connection name="artemis-cluster">
<address>jms</address>
<connector-ref>artemis-1S</connector-ref>
<check-period>1000</check-period>
<connection-ttl>5000</connection-ttl>
<min-large-message-size>50000</min-large-message-size>
<call-timeout>5000</call-timeout>
<retry-interval>500</retry-interval>
<retry-interval-multiplier>1.0</retry-interval-multiplier>
<max-retry-interval>5000</max-retry-interval>
<initial-connect-attempts>-1</initial-connect-attempts>
<reconnect-attempts>-1</reconnect-attempts>
<use-duplicate-detection>true</use-duplicate-detection>
<message-load-balancing>ON_DEMAND</message-load-balancing>
<max-hops>1</max-hops>
<confirmation-window-size>32000</confirmation-window-size>
<call-failover-timeout>30000</call-failover-timeout>
<notification-interval>1000</notification-interval>
<notification-attempts>2</notification-attempts>
<static-connectors allow-direct-connections-only="true">
<connector-ref>artemis-1M</connector-ref>
</static-connectors>
</cluster-connection>
</cluster-connections>
<connectors>
<connector name="artemis-1M">tcp://artemis-1M:61616</connector>
<connector name="artemis-1S">tcp://artemis-1S:61616</connector>
</connectors>
<acceptors>
<acceptor name="artemis">tcp://0.0.0.0:61616</acceptor>
</acceptors>
<security-settings>
<security-setting match="#">
<permission type="createNonDurableQueue" roles="amq"/>
<permission type="deleteNonDurableQueue" roles="amq"/>
<permission type="createDurableQueue" roles="amq"/>
<permission type="deleteDurableQueue" roles="amq"/>
<permission type="createAddress" roles="amq"/>
<permission type="deleteAddress" roles="amq"/>
<permission type="consume" roles="amq"/>
<permission type="browse" roles="amq"/>
<permission type="send" roles="amq"/>
<permission type="manage" roles="amq"/>
</security-setting>
</security-settings>
<address-settings>
<address-setting match="activemq.management#">
<dead-letter-address>DLQ</dead-letter-address>
<expiry-address>ExpiryQueue</expiry-address>
<redelivery-delay>0</redelivery-delay>
<max-size-bytes>-1</max-size-bytes>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<address-full-policy>PAGE</address-full-policy>
<auto-create-queues>true</auto-create-queues>
<auto-create-addresses>true</auto-create-addresses>
<auto-create-jms-queues>true</auto-create-jms-queues>
<auto-create-jms-topics>true</auto-create-jms-topics>
</address-setting>
<address-setting match="#">
<dead-letter-address>DLQ</dead-letter-address>
<expiry-address>ExpiryQueue</expiry-address>
<redelivery-delay>0</redelivery-delay>
<max-size-bytes>-1</max-size-bytes>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<address-full-policy>PAGE</address-full-policy>
<auto-create-queues>true</auto-create-queues>
<auto-create-addresses>true</auto-create-addresses>
<auto-create-jms-queues>true</auto-create-jms-queues>
<auto-create-jms-topics>true</auto-create-jms-topics>
</address-setting>
<address-setting match="jms.#">
<redistribution-delay>1000</redistribution-delay>
</address-setting>
</address-settings>
<addresses>
<address name="DLQ">
<anycast>
<queue name="DLQ" />
</anycast>
</address>
<address name="ExpiryQueue">
<anycast>
<queue name="ExpiryQueue" />
</anycast>
</address>
</addresses>
<broker-plugins>
<broker-plugin
class-name="org.apache.activemq.artemis.core.server.plugin.impl.LoggingActiveMQServerPlugin">
<property key="LOG_ALL_EVENTS" value="false"/>
<property key="LOG_CONNECTION_EVENTS" value="true"/>
<property key="LOG_SESSION_EVENTS" value="true"/>
<property key="LOG_CONSUMER_EVENTS" value="false"/>
<property key="LOG_DELIVERING_EVENTS" value="false"/>
<property key="LOG_SENDING_EVENTS" value="false"/>
<property key="LOG_INTERNAL_EVENTS" value="true"/>
</broker-plugin>
</broker-plugins>
</core>
</configuration>
...
This is the log of the first node:
2019-06-05 08:35:46,743 INFO
[org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting
ActiveMQ Artemis Server
2019-06-05 08:35:46,845 INFO [org.apache.activemq.artemis.core.server]
AMQ221000: live Message Broker is starting with configuration Broker
Configuration
(clustered=true,journalDirectory=vagrant_data/data/journal,bindingsDirectory=vagrant_data/data/bindings,largeMessagesDirectory=vagrant_data/data/large-messages,pagingDirectory=vagrant_data/data/paging)
2019-06-05 08:35:46,850 INFO [org.apache.activemq.artemis.core.server]
AMQ221006: Waiting to obtain live lock
2019-06-05 08:35:46,894 INFO [org.apache.activemq.artemis.core.server]
AMQ221012: Using AIO Journal
2019-06-05 08:35:46,971 INFO [org.apache.activemq.artemis.core.server]
AMQ221057: Global Max Size is being adjusted to 1/2 of the JVM max size
(-Xmx). being defined as 1,073,741,824
2019-06-05 08:35:47,127 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-server]. Adding protocol support
for: CORE
2019-06-05 08:35:47,129 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol
support for: AMQP
2019-06-05 08:35:47,136 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding
protocol support for: HORNETQ
2019-06-05 08:35:47,137 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol
support for: MQTT
2019-06-05 08:35:47,138 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding
protocol support for: OPENWIRE
2019-06-05 08:35:47,139 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol
support for: STOMP
2019-06-05 08:35:47,491 INFO [org.apache.activemq.artemis.core.server]
AMQ221034: Waiting indefinitely to obtain live lock
2019-06-05 08:35:47,492 INFO [org.apache.activemq.artemis.core.server]
AMQ221035: Live Server Obtained live lock
2019-06-05 08:35:49,177 INFO [org.apache.activemq.artemis.core.server]
AMQ221080: Deploying address DLQ supporting [ANYCAST]
2019-06-05 08:35:49,180 INFO [org.apache.activemq.artemis.core.server]
AMQ221003: Deploying ANYCAST queue DLQ on address DLQ
2019-06-05 08:35:49,180 INFO [org.apache.activemq.artemis.core.server]
AMQ221080: Deploying address ExpiryQueue supporting [ANYCAST]
2019-06-05 08:35:49,181 INFO [org.apache.activemq.artemis.core.server]
AMQ221003: Deploying ANYCAST queue ExpiryQueue on address ExpiryQueue
2019-06-05 08:35:49,609 INFO [org.apache.activemq.artemis.core.server]
AMQ221020: Started EPOLL Acceptor at 0.0.0.0:61616 for protocols
[CORE,MQTT,AMQP,HORNETQ,STOMP,OPENWIRE]
2019-06-05 08:35:49,611 INFO [org.apache.activemq.artemis.core.server]
AMQ221007: Server is now live
2019-06-05 08:35:49,611 INFO [org.apache.activemq.artemis.core.server]
AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.7.0 [artemis-1M,
nodeID=02e2a42a-788d-11e9-9148-08002741bcc2]
2019-06-05 08:35:50,103 INFO
[org.apache.activemq.hawtio.branding.PluginContextListener] Initialized
activemq-branding plugin
2019-06-05 08:35:50,284 INFO
[org.apache.activemq.hawtio.plugin.PluginContextListener] Initialized
artemis-plugin plugin
2019-06-05 08:35:51,182 INFO [io.hawt.HawtioContextListener] Initialising
hawtio services
2019-06-05 08:35:51,366 INFO [io.hawt.system.ConfigManager] Configuration
will be discovered via system properties
2019-06-05 08:35:51,371 INFO [io.hawt.jmx.JmxTreeWatcher] Welcome to hawtio
1.5.5 : http://hawt.io/ : Don't cha wish your console was hawt like me? ;-)
2019-06-05 08:35:51,459 INFO [io.hawt.jmx.UploadManager] Using file upload
directory: /var/lib/artemis/tmp/uploads
2019-06-05 08:35:51,521 INFO [io.hawt.web.AuthenticationFilter] Starting
hawtio authentication filter, JAAS realm: "activemq" authorized role(s):
"amq" role principal classes:
"org.apache.activemq.artemis.spi.core.security.jaas.RolePrincipal"
2019-06-05 08:35:51,665 INFO [io.hawt.web.JolokiaConfiguredAgentServlet]
Jolokia overridden property: [key=policyLocation,
value=file:/var/lib/artemis/etc/jolokia-access.xml]
2019-06-05 08:35:51,746 INFO [io.hawt.web.RBACMBeanInvoker] Using MBean
[hawtio:type=security,area=jmx,rank=0,name=HawtioDummyJMXSecurity] for role
based access control
2019-06-05 08:35:52,061 INFO [io.hawt.system.ProxyWhitelist] Initial proxy
whitelist: [localhost, 127.0.0.1, 192.168.1.10, artemis-1M]
2019-06-05 08:35:52,736 INFO [org.apache.activemq.artemis] AMQ241001: HTTP
Server started at http://192.168.1.10:8161
2019-06-05 08:35:52,736 INFO [org.apache.activemq.artemis] AMQ241002:
Artemis Jolokia REST API available at
http://192.168.1.10:8161/console/jolokia
2019-06-05 08:35:52,737 INFO [org.apache.activemq.artemis] AMQ241004:
Artemis Console available at http://192.168.1.10:8161/console
2019-06-05 08:35:59,254 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841000: created
connection: RemotingConnectionImpl [ID=8fb37d88, clientID=null,
nodeID=02e2a42a-788d-11e9-9148-08002741bcc2,
transportConnection=org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection@41b3270c[ID=8fb37d88,
local= /192.168.1.10:61616, remote=/192.168.1.20:49728]]
2019-06-05 08:35:59,254 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841000: created
connection: RemotingConnectionImpl [ID=afd3936a, clientID=null,
nodeID=02e2a42a-788d-11e9-9148-08002741bcc2,
transportConnection=org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection@7ba33ec6[ID=afd3936a,
local= /192.168.1.10:61616, remote=/192.168.1.20:49730]]
2019-06-05 08:35:59,357 WARN [org.apache.activemq.artemis.core.client]
AMQ212030: error sending topology: java.lang.NullPointerException
at
org.apache.activemq.artemis.core.server.cluster.impl.ClusterConnectionImpl.nodeUP(ClusterConnectionImpl.java:681)
[artemis-server-2.7.0.jar:2.7.0]
at
org.apache.activemq.artemis.core.client.impl.Topology$1.run(Topology.java:277)
[artemis-core-client-2.7.0.jar:2.7.0]
at
org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42)
[artemis-commons-2.7.0.jar:2.7.0]
at
org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31)
[artemis-commons-2.7.0.jar:2.7.0]
at
org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66)
[artemis-commons-2.7.0.jar:2.7.0]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[java.base:]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[java.base:]
at
org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
[artemis-commons-2.7.0.jar:2.7.0]
2019-06-05 08:49:00,751 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841000: created
connection: RemotingConnectionImpl [ID=b15a6db7, clientID=null,
nodeID=02e2a42a-788d-11e9-9148-08002741bcc2,
transportConnection=org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection@7bf9ca4f[ID=b15a6db7,
local= /192.168.1.10:61616, remote=/192.168.1.1:54350]]
2019-06-05 08:49:00,809 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 6ff28bdd-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:00,859 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 6ff28bdd-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:00,886 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 700158ee-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:00,915 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 700158ee-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:00,926 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 70085dcf-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:00,931 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 70085dcf-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:00,942 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 700b4400-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:00,951 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 700b4400-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:00,972 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 700fb0d1-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:00,985 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 700fb0d1-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,011 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7013f692-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,025 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7013f692-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,044 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 70194dc3-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,057 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 70194dc3-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,064 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 701e56d4-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,071 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 701e56d4-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,090 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7021d945-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,097 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7021d945-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,110 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 70249866-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,118 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 70249866-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,129 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7027ccb7-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,132 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7027ccb7-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,138 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 70295358-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,143 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 70295358-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,157 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 702beb69-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,162 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 702beb69-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,169 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 702e355a-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,175 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 702e355a-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,190 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7030a65b-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,193 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7030a65b-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,199 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7032a22c-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,202 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7032a22c-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,209 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 70344fdd-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,213 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 70344fdd-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,221 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7035fd8e-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,225 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7035fd8e-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,230 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7037842f-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,234 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7037842f-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,239 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 7038e3c0-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,242 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 7038e3c0-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:01,252 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 703ab881-87a9-11e9-9b9d-0a002700000e, session connectionID:
b15a6db7
2019-06-05 08:49:01,257 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 703ab881-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:08,039 INFO [io.hawt.web.LoginServlet] hawtio login is
using 1800 sec. HttpSession timeout
2019-06-05 08:49:11,962 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841000: created
connection: RemotingConnectionImpl [ID=87dd3f9c, clientID=null,
nodeID=02e2a42a-788d-11e9-9148-08002741bcc2,
transportConnection=org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection@3c24bb05[ID=87dd3f9c,
local= /192.168.1.10:61616, remote=/192.168.1.1:54366]]
2019-06-05 08:49:11,971 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 769e7684-87a9-11e9-9b9d-0a002700000e, session connectionID:
87dd3f9c
2019-06-05 08:49:11,974 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 769e7684-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
2019-06-05 08:49:11,992 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841002: created
session name: 76a15cb5-87a9-11e9-9b9d-0a002700000e, session connectionID:
87dd3f9c
2019-06-05 08:49:11,999 INFO
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841004: added
session metadata for session name : 76a15cb5-87a9-11e9-9b9d-0a002700000e,
key: jms-session, data:
...
This is the log of the second node:
2019-06-05 08:35:57,478 INFO
[org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting
ActiveMQ Artemis Server
2019-06-05 08:35:57,582 INFO [org.apache.activemq.artemis.core.server]
AMQ221000: backup Message Broker is starting with configuration Broker
Configuration
(clustered=true,journalDirectory=vagrant_data/data/journal,bindingsDirectory=vagrant_data/data/bindings,largeMessagesDirectory=vagrant_data/data/large-messages,pagingDirectory=vagrant_data/data/paging)
2019-06-05 08:35:57,597 INFO [org.apache.activemq.artemis.core.server]
AMQ221032: Waiting to become backup node
2019-06-05 08:35:57,601 INFO [org.apache.activemq.artemis.core.server]
AMQ221033: ** got backup lock
2019-06-05 08:35:57,812 INFO [org.apache.activemq.artemis.core.server]
AMQ221012: Using AIO Journal
2019-06-05 08:35:57,991 INFO [org.apache.activemq.artemis.core.server]
AMQ221057: Global Max Size is being adjusted to 1/2 of the JVM max size
(-Xmx). being defined as 1,073,741,824
2019-06-05 08:35:58,370 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-server]. Adding protocol support
for: CORE
2019-06-05 08:35:58,373 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol
support for: AMQP
2019-06-05 08:35:58,374 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding
protocol support for: HORNETQ
2019-06-05 08:35:58,375 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol
support for: MQTT
2019-06-05 08:35:58,376 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding
protocol support for: OPENWIRE
2019-06-05 08:35:58,396 INFO [org.apache.activemq.artemis.core.server]
AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol
support for: STOMP
2019-06-05 08:35:58,720 INFO
[org.apache.activemq.hawtio.branding.PluginContextListener] Initialized
activemq-branding plugin
2019-06-05 08:35:58,731 INFO [org.apache.activemq.artemis.core.server]
AMQ221109: Apache ActiveMQ Artemis Backup Server version 2.7.0
[fd506651-788c-11e9-a9f6-080027e3e6e8] started, waiting live to fail before
it gets active
2019-06-05 08:35:58,985 INFO
[org.apache.activemq.hawtio.plugin.PluginContextListener] Initialized
artemis-plugin plugin
2019-06-05 08:35:59,349 INFO [org.apache.activemq.artemis.core.server]
AMQ221031: backup announced
2019-06-05 08:36:00,200 INFO [io.hawt.HawtioContextListener] Initialising
hawtio services
2019-06-05 08:36:00,405 INFO [io.hawt.system.ConfigManager] Configuration
will be discovered via system properties
2019-06-05 08:36:00,410 INFO [io.hawt.jmx.JmxTreeWatcher] Welcome to hawtio
1.5.5 : http://hawt.io/ : Don't cha wish your console was hawt like me? ;-)
2019-06-05 08:36:00,499 INFO [io.hawt.jmx.UploadManager] Using file upload
directory: /var/lib/artemis/tmp/uploads
2019-06-05 08:36:00,549 INFO [io.hawt.web.AuthenticationFilter] Starting
hawtio authentication filter, JAAS realm: "activemq" authorized role(s):
"amq" role principal classes:
"org.apache.activemq.artemis.spi.core.security.jaas.RolePrincipal"
2019-06-05 08:36:00,622 INFO [io.hawt.web.JolokiaConfiguredAgentServlet]
Jolokia overridden property: [key=policyLocation,
value=file:/var/lib/artemis/etc/jolokia-access.xml]
2019-06-05 08:36:00,670 INFO [io.hawt.web.RBACMBeanInvoker] Using MBean
[hawtio:type=security,area=jmx,rank=0,name=HawtioDummyJMXSecurity] for role
based access control
2019-06-05 08:36:01,079 INFO [io.hawt.system.ProxyWhitelist] Initial proxy
whitelist: [localhost, 127.0.0.1, 192.168.1.20, artemis-1S]
2019-06-05 08:36:01,695 INFO [org.apache.activemq.artemis] AMQ241001: HTTP
Server started at http://192.168.1.20:8161
2019-06-05 08:36:01,696 INFO [org.apache.activemq.artemis] AMQ241002:
Artemis Jolokia REST API available at
http://192.168.1.20:8161/console/jolokia
2019-06-05 08:36:01,696 INFO [org.apache.activemq.artemis] AMQ241004:
Artemis Console available at http://192.168.1.20:8161/console
2019-06-05 08:49:10,079 INFO [io.hawt.web.LoginServlet] hawtio login is
using 1800 sec. HttpSession timeout
2019-06-05 08:50:18,831 INFO [io.hawt.web.keycloak.KeycloakServlet]
Keycloak integration is disabled
...
Here where the client application creates connections.
public static final String ARTEMIS_CLUSTER_URL_1M =
"(tcp://artemis-1M:61616,tcp://artemis-1S:61616)?ha=true&retryInterval=1000&reconnectAttempts=-1";
public static final String ARTEMIS_CLUSER_USERNAME =
"ACTIVEMQ.CLUSTER.ADMIN.USER";
public static final String ARTEMIS_CLUSTER_PASSWORD = "XxXxX";
ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(urlConfiguration,
runCfg.ARTEMIS_CLUSER_USERNAME,runCfg.ARTEMIS_CLUSTER_PASSWORD );
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
