activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Marlon Santos <msan...@exist.com>
Subject Re: 4.1 Master/Slave - Slave dies upon first conn to master
Date Thu, 14 Dec 2006 02:25:51 GMT

Oh I see, 

Well let's just hope that this is fixed sooner.

Regards...



William Blackburn-2 wrote:
> 
> Our app processes about 80 messages/sec using journaled-jdbc but only  
> 4-10 per sec using jdbc only.
> 
> I really need to use master/slave for performance reasons, but If it  
> doesn't work, I guess I'm outta luck...
> 
> Just noticed the JIRA you raised BTW (AMQ-1079) -- sadly no one has  
> commented on it yet.
> 
> BJ
> 
> On Dec 13, 2006, at 5:54 PM, Marlon Santos wrote:
> 
>>
>> Hi,
>>
>> IMHO, it is better to use a shared database master slave config  
>> because you
>> were using a database data source (postgresql in this case) rather  
>> than a
>> pure master slave which was explicitly shown in your configuration.  
>> By the
>> way, I also have had problems running a pure master slave config as  
>> of the
>> present. (Maybe there was a bug with the pure master slave  
>> configurations,
>> *i think*)
>>
>> Regards...
>>
>>
>> William Blackburn-2 wrote:
>>>
>>> I can't seem to get master slave working in 4.1 -- I configured the
>>> master and slave according to the instructions on the site. They
>>> start up OK, and I can see from the logs that the slave attaches to
>>> the master. But, as soon as the first connection is made to the
>>> master, the slave dies. The master log looks like:
>>>
>>> INFO  DefaultDatabaseLocker          - Attempting to acquire the
>>> exclusive lock to become the Master broker
>>> INFO  DefaultDatabaseLocker          - Becoming the master on
>>> dataSource: org.postgresql.ds.PGPoolingDataSource@724f31
>>> INFO  JournalPersistenceAdapter      - Journal Recovery Started from:
>>> Active Journal: using 5 x 20.0 Megs at: /Users/wblackburn/
>>> activemq-4.1.0-master/activemq-data/journal
>>> INFO  JournalPersistenceAdapter      - Journal Recovered: 0 message
>>> (s) in transactions recovered.
>>> INFO  TransportServerThreadSupport   - Listening for connections at:
>>> tcp://fastgt.local:61617
>>> INFO  TransportConnector             - Connector openwire Started
>>> INFO  BrokerService                  - ActiveMQ JMS Message Broker
>>> (localhost, ID:fastgt.local-50799-1166058345810-1:0) started
>>> INFO  TransportConnection            - Slave Broker localhost is
>>> attached
>>> ERROR MasterBroker                   - Slave Failed
>>> java.lang.AssertionError: Unsupported Method
>>>          at org.apache.activemq.transport.TransportSupport.request
>>> (TransportSupport.java:71)
>>>          at org.apache.activemq.transport.TransportFilter.request
>>> (TransportFilter.java:88)
>>>          at org.apache.activemq.transport.TransportFilter.request
>>> (TransportFilter.java:88)
>>>          at org.apache.activemq.transport.MutexTransport.request
>>> (MutexTransport.java:49)
>>>          at  
>>> org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave
>>> (MasterBroker.java:363)
>>>          at org.apache.activemq.broker.ft.MasterBroker.sendToSlave
>>> (MasterBroker.java:345)
>>>          at org.apache.activemq.broker.ft.MasterBroker.acknowledge
>>> (MasterBroker.java:320)
>>>          at  
>>> org.apache.activemq.broker.MutableBrokerFilter.acknowledge
>>> (MutableBrokerFilter.java:88)
>>>          at
>>> org.apache.activemq.broker.TransportConnection.processMessageAck
>>> (TransportConnection.java:488)
>>>          at org.apache.activemq.command.MessageAck.visit
>>> (MessageAck.java:179)
>>>          at org.apache.activemq.broker.TransportConnection.service
>>> (TransportConnection.java:284)
>>>          at org.apache.activemq.broker.TransportConnection 
>>> $1.onCommand
>>> (TransportConnection.java:177)
>>>          at org.apache.activemq.transport.TransportFilter.onCommand
>>> (TransportFilter.java:65)
>>>          at
>>> org.apache.activemq.transport.WireFormatNegotiator.onCommand
>>> (WireFormatNegotiator.java:133)
>>>          at org.apache.activemq.transport.InactivityMonitor.onCommand
>>> (InactivityMonitor.java:122)
>>>          at org.apache.activemq.transport.TransportSupport.doConsume
>>> (TransportSupport.java:84)
>>>          at org.apache.activemq.transport.tcp.TcpTransport.run
>>> (TcpTransport.java:137)
>>>          at java.lang.Thread.run(Thread.java:613)
>>> ERROR MasterBroker                   - Slave Failed
>>>
>>> master config is:
>>>
>>> <!--
>>>      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.
>>> -->
>>> <!-- START SNIPPET: example -->
>>> <beans>
>>>
>>>    <!-- Allows us to use system properties as variables in this
>>> configuration file -->
>>>    <bean
>>> class="org.springframework.beans.factory.config.PropertyPlaceholderCo 
>>> nfi
>>> gurer"/>
>>>
>>>    <broker brokerName="localhost" useJmx="true" xmlns="http://
>>> activemq.org/config/1.0">
>>>
>>>      <persistenceAdapter>
>>>          <journaledJDBC journalLogFiles="5" dataDirectory="$
>>> {activemq.base}/activemq-data" dataSource="#postgres-ds"/>
>>>      </persistenceAdapter>
>>>
>>>      <transportConnectors>
>>>         <transportConnector name="openwire" uri="tcp://localhost:
>>> 61617"/>
>>>      </transportConnectors>
>>>
>>>    </broker>
>>>
>>>    <!--  This xbean configuration file supports all the standard
>>> spring xml configuration options -->
>>>
>>>    <!-- Postgres DataSource Sample Setup -->
>>>      <bean id="postgres-ds"
>>> class="org.postgresql.ds.PGPoolingDataSource">
>>>          <property name="serverName" value="localhost"/>
>>>          <property name="databaseName" value="activemq"/>
>>>          <property name="portNumber" value="0"/>
>>>          <property name="user" value="activemq"/>
>>>          <property name="password" value="activemq"/>
>>>          <property name="dataSourceName" value="postgres"/>
>>>          <property name="initialConnections" value="1"/>
>>>          <property name="maxConnections" value="10"/>
>>>      </bean>
>>>
>>> </beans>
>>>
>>>
>>>
>>> The slave log looks like:
>>>
>>> INFO  DefaultDatabaseLocker          - Attempting to acquire the
>>> exclusive lock to become the Master broker
>>> INFO  DefaultDatabaseLocker          - Becoming the master on
>>> dataSource: org.postgresql.ds.PGPoolingDataSource@bcd14a
>>> INFO  JournalPersistenceAdapter      - Journal Recovery Started from:
>>> Active Journal: using 5 x 20.0 Megs at: /Users/wblackburn/
>>> activemq-4.1.0-slave/activemq-data/journal
>>> INFO  JournalPersistenceAdapter      - Journal Recovered: 0 message
>>> (s) in transactions recovered.
>>> INFO  TransportServerThreadSupport   - Listening for connections at:
>>> tcp://fastgt.local:61618
>>> INFO  TransportConnector             - Connector openwire Started
>>> INFO  TransportConnector             - Connector vm://localhost  
>>> Started
>>> INFO  MasterConnector                - Starting a network connection
>>> between vm://localhost#0 and tcp://null:0 has been established.
>>> INFO  BrokerService                  - ActiveMQ JMS Message Broker
>>> (localhost, ID:fastgt.local-50808-1166058365982-2:0) started
>>> INFO  MasterConnector                - Slave connection between vm://
>>> localhost#0 and tcp://localhost/127.0.0.1:61617 has been established.
>>>
>>> Slave config is:
>>>
>>> <beans>
>>>
>>>    <!-- Allows us to use system properties as variables in this
>>> configuration file -->
>>>    <bean
>>> class="org.springframework.beans.factory.config.PropertyPlaceholderCo 
>>> nfi
>>> gurer"/>
>>>
>>>    <broker brokerName="localhost" useJmx="true" xmlns="http://
>>> activemq.org/config/1.0" masterConnectorURI="tcp://localhost:61617"
>>> shutdownOnMasterFailure="false">
>>>
>>>      <persistenceAdapter>
>>>          <journaledJDBC journalLogFiles="5" dataDirectory="$
>>> {activemq.base}/activemq-data" dataSource="#postgres-ds"/>
>>>      </persistenceAdapter>
>>>
>>>      <transportConnectors>
>>>         <transportConnector name="openwire" uri="tcp://localhost:
>>> 61618"/>
>>>      </transportConnectors>
>>>
>>>    </broker>
>>>
>>>    <!--  This xbean configuration file supports all the standard
>>> spring xml configuration options -->
>>>
>>> <!-- Postgres DataSource Sample Setup -->
>>>      <bean id="postgres-ds"
>>> class="org.postgresql.ds.PGPoolingDataSource">
>>>          <property name="serverName" value="localhost"/>
>>>          <property name="databaseName" value="amqslave"/>
>>>          <property name="portNumber" value="0"/>
>>>          <property name="user" value="activemq"/>
>>>          <property name="password" value="activemq"/>
>>>          <property name="dataSourceName" value="postgres"/>
>>>          <property name="initialConnections" value="1"/>
>>>          <property name="maxConnections" value="10"/>
>>>      </bean>
>>>
>>>
>>> </beans>
>>>
>>>
>>>
>>>
>>
>> -- 
>> View this message in context: http://www.nabble.com/4.1-Master- 
>> Slave---Slave-dies-upon-first-conn-to-master-tf2817915.html#a7865521
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/4.1-Master-Slave---Slave-dies-upon-first-conn-to-master-tf2817915.html#a7865808
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message