activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ptomsic <ptom...@gmail.com>
Subject cluster problem, journal conflict?
Date Fri, 05 May 2006 19:53:28 GMT

i've got 3 machines where i'm trying to cluster activemq brokers.
i can get 2 to start up just fine, but the third box starts up and says,
"Journal is already open..."  then "Could not connect to local URI:
vm:?network=true"

why do 2 machines successfully link, but the third blows up?
any thoughts?

here's the relevant parts of my configuration (and the stack trace is
beneath that)


     <amq:persistenceAdapter>
            <amq:journalPersistenceAdapter>
                <constructor-arg index="0">
                    <ref bean="myJournalImpl"/>
                </constructor-arg>
                <constructor-arg index="1">
                    <amq:memoryPersistenceAdapter
init-method="createTransactionStore"/>
                </constructor-arg>
                <constructor-arg index="2">
                    <bean id="myTaskRunnerFactory"
class="org.apache.activemq.thread.TaskRunnerFactory"/>
                </constructor-arg>
            </amq:journalPersistenceAdapter>


        </amq:persistenceAdapter>

        <amq:transportConnectors>
            <amq:transportConnector uri="tcp://localhost:0"
discoveryUri="multicast://default"/>

        </amq:transportConnectors>

        <amq:networkConnectors>
            <!-- by default just auto discover the other brokers -->
            <amq:networkConnector uri="multicast://default"/>

        </amq:networkConnectors>

    </amq:broker>
    <bean id="myJournalImpl"
class="org.apache.activeio.journal.active.JournalImpl">
        <constructor-arg index="0">
            <bean id="myFile" class="java.io.File">
                <constructor-arg index="0">
                    <value>/home/ptomsic/projects/mbus/journal</value>
                </constructor-arg>
            </bean>
        </constructor-arg>
    </bean>


----------
[EGHOST03 ~/projects/mbus/conf ]$ activemq xbean:file:./03_A.xml
ACTIVEMQ_HOME: /home/ptomsic/packages/activemq-4.0-RC2
Loading message broker from: xbean:file:./03_A.xml
INFO  BrokerService                  - ActiveMQ 4.0-RC2 JMS Message Broker
(03_A) is starting
INFO  BrokerService                  - For help or more information please
see: http://incubator.apache.org/activemq/
INFO  JournalPersistenceAdapter      - Journal Recovery Started from: Active
Journal: using 2 x 20.0 Megs at: /home/ptomsic/projects/mbu s/03/A/journal
INFO  ManagementContext              - JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
INFO  JournalPersistenceAdapter      - Journal Recovered: 0 message(s) in
transactions recovered.
INFO  TransportServerThreadSupport   - Listening for connections at:
tcp://eghost03.dev.o.com:34095
WARN  MulticastDiscoveryAgent        - brokerName not set
INFO  TransportConnector             - Connector
tcp://eghost03.dev.o.com:34095 Started
INFO  NetworkConnector               - Network Connector bridge Started
INFO  BrokerService                  - ActiveMQ JMS Message Broker (03_A)
started
INFO  NetworkConnector               - Establishing network connection
between from vm:?network=true to tcp://eghost02.dev.o.com:34600
INFO  BrokerService                  - ActiveMQ 4.0-RC2 JMS Message Broker
(null) is starting
INFO  BrokerService                  - For help or more information please
see: http://incubator.apache.org/activemq/
INFO  JDBCPersistenceAdapter         - Database driver recognized:
[apache_derby_embedded_jdbc_driver]
INFO  JournalPersistenceAdapter      - Journal Recovery Started from: Active
Journal: using 2 x 20.0 Megs at: /home/ptomsic/projects/mbu
s/conf/activemq-data/null/journal
INFO  JournalPersistenceAdapter      - Journal Recovered: 0 message(s) in
transactions recovered.
INFO  BrokerService                  - ActiveMQ JMS Message Broker (null)
started
INFO  VMTransportFactory             - binding to broker: null
INFO  TransportConnector             - Connector vm://null Started
INFO  DemandForwardingBridge         - Starting a network connection between
vm://null#0 and tcp://null:0 has been established.
INFO  DemandForwardingBridge         - Network connection between
vm://null#0 and tcp://eghost02.dev.o.com/10.229.129.77:34600(02_A) has  been
established.
INFO  NetworkConnector               - Establishing network connection
between from vm:?network=true to tcp://eghost01.dev.o.com:35379
INFO  VMTransportFactory             - Shutting down VM connectors for
broker: null
INFO  DemandForwardingBridge         - 03_A Shutting down
INFO  VMTransportFactory             - Shutting down VM connectors for
broker: null
INFO  TransportConnector             - Connector vm://null Stopped
INFO  BrokerService                  - ActiveMQ 4.0-RC2 JMS Message Broker
(null) is starting
INFO  BrokerService                  - For help or more information please
see: http://incubator.apache.org/activemq/
ERROR BrokerService                  - Failed to start ActiveMQ JMS Message
Broker. Reason: java.io.IOException: Journal is already open ed by this
application.
java.io.IOException: Journal is already opened by this application.
        at
org.apache.activeio.journal.active.ControlFile.lock(ControlFile.java:71)
        at
org.apache.activeio.journal.active.LogFileManager.initialize(LogFileManager.java:120)
        at
org.apache.activeio.journal.active.LogFileManager.<init>(LogFileManager.java:101)
        at
org.apache.activeio.journal.active.JournalImpl.<init>(JournalImpl.java:99)
        at
org.apache.activemq.store.DefaultPersistenceAdapterFactory.createJournal(DefaultPersistenceAdapterFactory.java:198)
        at
org.apache.activemq.store.DefaultPersistenceAdapterFactory.getJournal(DefaultPersistenceAdapterFactory.java:134)
        at
org.apache.activemq.store.DefaultPersistenceAdapterFactory.createPersistenceAdapter(DefaultPersistenceAdapterFactory.java:63)
        at
org.apache.activemq.broker.BrokerService.createPersistenceAdapter(BrokerService.java:945)
        at
org.apache.activemq.broker.BrokerService.getPersistenceAdapter(BrokerService.java:530)
        at
org.apache.activemq.broker.BrokerService.createRegionBroker(BrokerService.java:906)
        at
org.apache.activemq.broker.BrokerService.createBroker(BrokerService.java:867)
        at
org.apache.activemq.broker.BrokerService.getBroker(BrokerService.java:447)
        at
org.apache.activemq.broker.BrokerService.start(BrokerService.java:356)
        at
org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConnect(VMTransportFactory.java:102)
        at
org.apache.activemq.transport.vm.VMTransportFactory.doConnect(VMTransportFactory.java:48)
        at
org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:63)
        at
org.apache.activemq.network.NetworkConnector.createLocalTransport(NetworkConnector.java:282)
        at
org.apache.activemq.network.DiscoveryNetworkConnector.onServiceAdd(DiscoveryNetworkConnector.java:95)
        at
org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent$2.run(MulticastDiscoveryAgent.java:330)
        at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
        at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
        at java.lang.Thread.run(Thread.java:595)
WARN  NetworkConnector               - Could not connect to local URI:
vm:?network=true: java.io.IOException: Journal is already opened by this
application.
java.io.IOException: Journal is already opened by this application.
        at
org.apache.activeio.journal.active.ControlFile.lock(ControlFile.java:71)
        at
org.apache.activeio.journal.active.LogFileManager.initialize(LogFileManager.java:120)
        at
org.apache.activeio.journal.active.LogFileManager.<init>(LogFileManager.java:101)
        at
org.apache.activeio.journal.active.JournalImpl.<init>(JournalImpl.java:99)
        at
org.apache.activemq.store.DefaultPersistenceAdapterFactory.createJournal(DefaultPersistenceAdapterFactory.java:198)
        at
org.apache.activemq.store.DefaultPersistenceAdapterFactory.getJournal(DefaultPersistenceAdapterFactory.java:134)
        at
org.apache.activemq.store.DefaultPersistenceAdapterFactory.createPersistenceAdapter(DefaultPersistenceAdapterFactory.java:63)
        at
org.apache.activemq.broker.BrokerService.createPersistenceAdapter(BrokerService.java:945)
        at
org.apache.activemq.broker.BrokerService.getPersistenceAdapter(BrokerService.java:530)
        at
org.apache.activemq.broker.BrokerService.createRegionBroker(BrokerService.java:906)
        at
org.apache.activemq.broker.BrokerService.createBroker(BrokerService.java:867)
        at
org.apache.activemq.broker.BrokerService.getBroker(BrokerService.java:447)
        at
org.apache.activemq.broker.BrokerService.start(BrokerService.java:356)
        at
org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConnect(VMTransportFactory.java:102)
        at
org.apache.activemq.transport.vm.VMTransportFactory.doConnect(VMTransportFactory.java:48)
        at
org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:63)
        at
org.apache.activemq.network.NetworkConnector.createLocalTransport(NetworkConnector.java:282)
        at
org.apache.activemq.network.DiscoveryNetworkConnector.onServiceAdd(DiscoveryNetworkConnector.java:95)
        at
org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent$2.run(MulticastDiscoveryAgent.java:330)
        at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
        at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
        at java.lang.Thread.run(Thread.java:595)
WARN  ManagedTransportConnection     - Failed to unregister mbean:
org.apache.activemq:BrokerName=03_A,Type=Connection,Connection=6
WARN  ManagedTransportConnection     - Failed to unregister mbean:
org.apache.activemq:BrokerName=03_A,Type=Connection,Connection=7
 

--
View this message in context: http://www.nabble.com/cluster-problem%2C-journal-conflict--t1566053.html#a4253139
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message