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.