Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

The servers participating in a network of brokers must have a networkConnections element in their activemq.xml. Do note that the elements within the <broker> elements *must* appear alphabetically - otherwise the server will fail without notice!

This is the configuation file for instance1 on sandkasse-01:

Code Block
Wiki Markup
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="\[http://www.springframework.org/schema/beans\|http://www.springframework.org/schema/beans\]" xmlns:amq="\[http://activemq.apache.org/schema/core\|http://activemq.apache.org/schema/core\]" xmlns:xsi="\[http://www.w3.org/2001/XMLSchema-instance\|http://www.w3.org/2001/XMLSchema-instance\]" xsi:schemaLocation="\[http://www.springframework.org/schema/beans\|http://www.springframework.org/schema/beans\] \[http://www.springframework.org/schema/beans/spring-beans-2.0.xsd\|http://www.springframework.org/schema/beans/spring-beans-2.0.xsd\]&nbsp;&nbsp; \[http://activemq.apache.org/schema/core\|http://activemq.apache.org/schema/core\] \[http://activemq.apache.org/schema/core/activemq-core.xsd\|http://activemq.apache.org/schema/core/activemq-core.xsd\]">

&nbsp;&nbsp;&nbsp; <\!-\\- Allows us to use system properties as variables in this configuration file \-->
&nbsp;&nbsp;&nbsp; <bean>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <property name="locations">
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <value>file:${activemq.base}/conf/credentials.properties</value>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </property>
&nbsp;&nbsp;&nbsp; </bean>

&nbsp;&nbsp;&nbsp; <\!-\\-
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The <broker> element is used to configure the ActiveMQ broker.
&nbsp;&nbsp;&nbsp; \-->
&nbsp;&nbsp;&nbsp; <broker xmlns="\[http://activemq.apache.org/schema/core\|http://activemq.apache.org/schema/core\]" brokerName="instance1" dataDirectory="${activemq.base}/data" destroyApplicationContextOnStop="true">

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <\!-\\-
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; For better performances use VM cursor and small memory limit.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; For more information, see:

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \[http://activemq.apache.org/message-cursors.html\|http://activemq.apache.org/message-cursors.html\]

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Also, if your producer is "hanging", it's probably due to producer flow control.
's probably due to producer flow control.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; For more information, see:
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \[http://activemq.apache.org/producer-flow-control.html\|http://activemq.apache.org/producer-flow-control.html\]
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \-->

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <destinationPolicy>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <policyMap>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <policyEntries>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <policyEntry memoryLimit="1mb" producerFlowControl="true" topic="&gt;">
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <pendingSubscriberPolicy>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <vmCursor/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </pendingSubscriberPolicy>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </policyEntry>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <policyEntry memoryLimit="1mb" producerFlowControl="true" queue="&gt;">
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <\!-\\- Use VM cursor for better latency
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; For more information, see:

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \[http://activemq.apache.org/message-cursors.html\|http://activemq.apache.org/message-cursors.html\]

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <pendingQueuePolicy>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <vmQueueCursor/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </pendingQueuePolicy>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \-->
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </policyEntry>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </policyEntries>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </policyMap>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </destinationPolicy>

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <\!-\\-
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The managementContext is used to configure how ActiveMQ is exposed in
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; JMX. By default, ActiveMQ uses the MBean server that is started by
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; the JVM. For more information, see:

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \[http://activemq.apache.org/jmx.html\|http://activemq.apache.org/jmx.html\]
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \-->
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <managementContext>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <managementContext createConnector="false"/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </managementContext>

{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <\!-\-{color}
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Added by csv 20110530:{color}
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The network connectors enumerate other brokers participating in{color}
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; a network of brokers{color}
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {color} \[http://activemq.apache.org/networks-of-brokers.html\|http://activemq.apache.org/networks-of-brokers.html\]
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \-->{color}

{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <networkConnectors>{color}
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <networkConnector name="instance2" uri="static:(tcp://localhost:60002)"/>{color}
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <networkConnector name="instance3" uri="static:(tcp://localhost:60003)"/>{color}
{color:#800000}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </networkConnectors>{color}

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <\!-\\-
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Configure message persistence for the broker. The default persistence
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; mechanism is the KahaDB store (identified by the kahaDB tag).
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; For more information, see:

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \[http://activemq.apache.org/persistence.html\|http://activemq.apache.org/persistence.html\]
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \-->
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <persistenceAdapter>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <kahaDB directory="${activemq.base}/data/kahadb"/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </persistenceAdapter>

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <\!-\\-
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The systemUsage controls the maximum amount of space the broker will
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; use before slowing down producers. For more information, see:

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \[http://activemq.apache.org/producer-flow-control.html\|http://activemq.apache.org/producer-flow-control.html\]

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <systemUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <systemUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <memoryUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <memoryUsage limit="20 mb"/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </memoryUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <storeUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <storeUsage limit="1 gb"/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </storeUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <tempUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <tempUsage limit="100 mb"/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </tempUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </systemUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </systemUsage>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \-->

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <\!-\\-
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The transport connectors expose ActiveMQ over a given protocol to
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; clients and other brokers. For more information, see:

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \[http://activemq.apache.org/configuring-transports.html\|http://activemq.apache.org/configuring-transports.html\]
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \-->
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <transportConnectors>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <transportConnector name="openwire" uri="tcp://0.0.0.0:60001"/>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </transportConnectors>

&nbsp;&nbsp;&nbsp; </broker>

&nbsp;&nbsp;&nbsp; <\!-\\-
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Enable web consoles, REST and Ajax APIs and demos
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; It also includes Camel (with its web console), see ${ACTIVEMQ_HOME}/conf/camel.xml for more info

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Take a look at ${ACTIVEMQ_HOME}/conf/jetty.xml for more details
&nbsp;&nbsp;&nbsp; \-->
&nbsp;&nbsp;&nbsp; <import resource="jetty.xml"/>

</beans>

&nbsp;
\\