attached: activemq-centos-test1.xml for broker 1
attached: activemq-centos-test3.xml for broker 2.
On Wed, Aug 22, 2012 at 3:46 PM, ceposta <christian.po...@gmail.com> wrote:
> From your logs:
>
> sk92129 wrote
>>
>> 2012-08-22 12:58:21,363 | INFO | Listening for connections at:
>> ssl://centos-test1.foo.com:61616?needClientAuth=true |
>> org.apache.activemq.transport.TransportServerThreadSupport | main
>>
>
> You can see from your config:
>
>
> sk92129 wrote
>>
>> <transportConnectors>
>> <transportConnector name="openwire"
>> uri="ssl://0.0.0.0:61616?needClientAuth=true" >
>> </transportConnector>
>> </transportConnectors>
>>
>
> The transport connector has been opened on the appropriate port.
>
> I wonder if what you're seeing is the outgoing port on the local machine
> that's being used to connect to the networked broker.
>
> Wanna post your network connector configs?
>
>
>
> -----
> http://www.christianposta.com/blog
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/iptables-and-broker-to-broker-transport-tp4655452p4655461.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd
http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd";>
<!-- Allows us to use system properties as variables in this configuration file -->
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
<broker useJmx="true" xmlns="http://activemq.apache.org/schema/core"; brokerName="static-broker-centos-test1" dataDirectory="${activemq.data}">
<!-- Destination specific policies using destination names or wildcards -->
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" producerFlowControl="true" memoryLimit="20mb">
<deadLetterStrategy>
<individualDeadLetterStrategy queuePrefix="DLQ." useQueueForQueueMessages="true" />
</deadLetterStrategy>
</policyEntry>
<policyEntry topic=">" producerFlowControl="true" memoryLimit="20mb">
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<!-- Use the following to configure how ActiveMQ is exposed in JMX -->
<managementContext>
<managementContext createConnector="true" connectorPort="2011"/>
</managementContext>
<!--
The store and forward broker networks ActiveMQ will listen to
Create a duplex connector to the first broker
-->
<networkConnectors>
</networkConnectors>
<persistenceAdapter>
<kahaDB directory="${activemq.data}/static-broker/kahadb" />
</persistenceAdapter>
<sslContext>
<sslContext keyStore="file:/home/keystore/centos-test1.ks"
keyStorePassword="password"
trustStore="file:/home/keystore/centos-test1.ts"
trustStorePassword="password"
/>
</sslContext>
<!-- The maximum amount of space the broker will use before slowing down producers -->
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="20 mb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="1 gb" name="foo"/>
</storeUsage>
<tempUsage>
<tempUsage limit="100 mb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<!-- The transport connectors ActiveMQ will listen to -->
<transportConnectors>
<transportConnector name="openwire" uri="ssl://0.0.0.0:61616?needClientAuth=true" >
</transportConnector>
</transportConnectors>
</broker>
<import resource="jetty.xml" />
</beans>
<!--
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
-->
<!--
Create a static network of brokers
For more information, see:
http://activemq.apache.org/networks-of-brokers.html
To run this example network of ActiveMQ brokers run
$ bin/activemq console xbean:conf/activemq-static-network-broker1.xml
and
$ bin/activemq console xbean:conf/activemq-static-network-broker2.xml
in separate consoles
-->
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd
http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd";>
<!-- Allows us to use system properties as variables in this configuration file -->
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
<broker useJmx="true" xmlns="http://activemq.apache.org/schema/core"; brokerName="static-broker-centos-test3" dataDirectory="${activemq.data}"
>
<!-- Destination specific policies using destination names or wildcards -->
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" producerFlowControl="true" memoryLimit="20mb">
<deadLetterStrategy>
<individualDeadLetterStrategy queuePrefix="DLQ." useQueueForQueueMessages="true" />
</deadLetterStrategy>
</policyEntry>
<policyEntry topic=">" producerFlowControl="true" memoryLimit="20mb">
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<!-- Use the following to configure how ActiveMQ is exposed in JMX -->
<managementContext>
<managementContext createConnector="true" connectorPort="2011"/>
</managementContext>
<!--
The store and forward broker networks ActiveMQ will listen to
Create a duplex connector to the first broker
-->
<networkConnectors>
<networkConnector uri="static:(ssl://centos-test1:61616)" duplex="true"/>
</networkConnectors>
<persistenceAdapter>
<kahaDB directory="${activemq.data}/static-broker/kahadb" />
</persistenceAdapter>
<plugins>
<bean xmlns="http://www.springframework.org/schema/beans"; id="myPlugin" class="com.aseg.jms.broker.MyLoggingPlugin" />
</plugins>
<sslContext>
<sslContext
keyStore="file:/home/keystore/centos-test3.ks"
keyStorePassword="password"
trustStore="file:/home/keystore/centos-test3.ts"
trustStorePassword="password"
/>
</sslContext>
<!-- The maximum amount of space the broker will use before slowing down producers -->
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="20 mb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="1 gb" name="foo"/>
</storeUsage>
<tempUsage>
<tempUsage limit="100 mb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<!-- The transport connectors ActiveMQ will listen to -->
<transportConnectors>
<transportConnector name="openwire" uri="ssl://0.0.0.0:61616?needClientAuth=true">
</transportConnector>
</transportConnectors>
</broker>
<import resource="jetty.xml" />
</beans>
