activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chahir <chahi...@yahoo.fr>
Subject SocketTimeOutException
Date Tue, 15 May 2007 14:13:51 GMT

Hi everybody,

I want to connect two brokers on 2 different hosts and to send/receive
messages to/from distributed queues.
The two brokers start but display the following message:


INFO  TransportConnector             - Connector vm://Broker1 Started
INFO  NetworkConnector               - Establishing network connection
between from vm://Broker1 to tcp://10.24.246.26:61661
INFO  DemandForwardingBridge         - Disconnecting loop back connection.
INFO  DemandForwardingBridge         - Broker1 bridge to Broker1 stopped
INFO  TransportConnector             - Connector vm://Broker1 Stopped
WARN  NetworkConnector               - Could not start network bridge
between: vm://Broker1 and: tcp://10.24.246.26:61661 due to:
java.net.SocketTimeoutException: connect timed out
INFO  DemandForwardingBridge         - Broker1 bridge to Unknown stopped
INFO  NetworkConnector               - Network Connector
org.apache.activemq.transport.discovery.simple.SimpleDiscoveryAgent@11a75a2
Started
INFO  BrokerService                  - ActiveMQ JMS Message Broker (Broker1,
ID:chahir-19651-1179234468285-1:0) started
INFO  NetworkConnector               - Establishing network connection
between from vm://Broker1 to tcp://10.24.246.26:61661
INFO  TransportConnector             - Connector vm://Broker1 Started
INFO  TransportConnector             - Connector vm://Broker1 Stopped
WARN  NetworkConnector               - Could not start network bridge
between: vm://Broker1 and: tcp://10.24.246.26:61661 due to:
java.net.SocketTimeoutException: connect timed out

My activemq.xml files are:

Broker2:

<beans>

  
  <beans>

  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  
  <broker xmlns="http://activemq.org/config/1.0" brokerName="Broker2"
dataDirectory="${activemq.base}/data">
  
    <destinationPolicy>
      <policyMap>
        <policyEntries>

          <policyEntry topic="FOO.>">
            <dispatchPolicy>
              <strictOrderDispatchPolicy/>
            </dispatchPolicy>
            <subscriptionRecoveryPolicy>
              <lastImageSubscriptionRecoveryPolicy/>
            </subscriptionRecoveryPolicy>
          </policyEntry>

        </policyEntries>
      </policyMap>
    </destinationPolicy>
   
    <transportConnectors>
       <transportConnector name="openwire" uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
       <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
       <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
       <transportConnector name="xmpp"    uri="xmpp://localhost:61222"/>
    </transportConnectors>

    <networkConnectors>
     <networkConnector name="P2P"
uri="static://(tcp://10.24.247.242:61616,tcp://10.24.246.26:61616)"/>
     </networkConnectors>

</broker>

 <commandAgent xmlns="http://activemq.org/config/1.0"/>
  <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">
    <connectors>
      <nioConnector port="8161" />
    </connectors>

    <handlers>
      <webAppContext contextPath="/admin"
resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" />
      <webAppContext contextPath="/demo"
resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" />
    </handlers>
  </jetty>

</beans>

_______________________________________
Broker 3:

<beans>

  
  <beans>

  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  
  <broker xmlns="http://activemq.org/config/1.0" brokerName="Broker3"
dataDirectory="${activemq.base}/data">
  
    <destinationPolicy>
      <policyMap>
        <policyEntries>

          <policyEntry topic="FOO.>">
            <dispatchPolicy>
              <strictOrderDispatchPolicy/>
            </dispatchPolicy>
            <subscriptionRecoveryPolicy>
              <lastImageSubscriptionRecoveryPolicy/>
            </subscriptionRecoveryPolicy>
          </policyEntry>

        </policyEntries>
      </policyMap>
    </destinationPolicy>
   
    <transportConnectors>
       <transportConnector name="openwire" uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
       <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
       <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
       <transportConnector name="xmpp"    uri="xmpp://localhost:61222"/>
    </transportConnectors>

    <networkConnectors>
     <networkConnector name="P2P"
uri="static://(tcp://10.24.247.242:61616,tcp://10.24.246.26:61616)"/>
     </networkConnectors>

</broker>

 <commandAgent xmlns="http://activemq.org/config/1.0"/>
  <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">
    <connectors>
      <nioConnector port="8161" />
    </connectors>

    <handlers>
      <webAppContext contextPath="/admin"
resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" />
      <webAppContext contextPath="/demo"
resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" />
    </handlers>
  </jetty>

</beans>

____________________________

What's the problem?
Thx.
-- 
View this message in context: http://www.nabble.com/SocketTimeOutException-tf3758715s2354.html#a10623640
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.


Mime
View raw message