[activemq-user] Configuring Network Of Brokers

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
7 messages Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

[activemq-user] Configuring Network Of Brokers

DOSSOT David
Hi all,
 
Despite real efforts to RTFMs, I have troubles with the configuration of
a network of standalone brokers, using ZeronConf for the discovery.
 
I have two brokers on two different machines, Alpha and Beta, both
configured the same way:

         <broker name="Alpha">
          <connector>
           <tcpServerTransport uri="tcp://localhost:62002"/>
          </connector>
          <discoveryAgent>
           <zeroconfDiscovery type="_activemq.broker.development."/>
          </discoveryAgent>
          <discoveryNetworkConnector/>
          <persistence>
           <vmPersistence/>
          </persistence>
         </broker>

When starting the brokers, I can see them discover each other:

        ActiveMQ Message Broker
         
        Loading Mesaage Broker from activemq.xml on the CLASSPATH
        14:17:44 INFO  ActiveMQ 3.0 JMS Message Broker (Alpha) is
starting
        14:17:44 INFO  For help or more information please see:
www.protique.com <http://www.protique.com>
        14:17:44 INFO  Listening for connections at:
tcp://PRESLUXWISPSP21:62002
        14:17:44 INFO  ActiveMQ connector started:
TcpTransportServerChannel@tcp://PRESLUXWISPSP21:62002
<mailto:TcpTransportServerChannel@tcp://PRESLUXWISPSP21:62002>
        14:17:44 INFO  Discovering service of type:
_activemq.broker.development.
        14:17:44 INFO  Alpha: Adding new NeworkChannel on:
reliable:tcp://PRESLUXWISPSP16:62002{resolved=reliable:tcp://PRESLUXWISP
SP16:62002} with
        details: {connectURL=reliable:tcp://PRESLUXWISPSP16:62002,
brokerName=Beta}
        14:17:44 INFO  Listening for connections at: vm://Alpha
        14:17:44 INFO  ActiveMQ connector started:
VmTransportServerChannel@vm://Alpha
<mailto:VmTransportServerChannel@vm://Alpha>
        14:17:44 INFO  Embedded JMS Broker has started
        14:17:45 INFO  ActiveMQ JMS Message Broker (Alpha) has started
        14:17:46 INFO  Adding new client:
ID:PRESLUXWISPSP21-1862-1118924263129-5:0 on transport:
VmTransportChannel: null
        14:17:46 INFO  channel status changed: Channel:
ReliableTransportChannel: TcpTransportChannel:
Socket[addr=presluxwispsp16/136.173.11.37,port=62002,localport=1863] has
connected
        14:17:46 INFO  Adding new client: Beta_NetworkChannel on
transport: TcpTransportChannel:
Socket[addr=/136.173.11.37,port=1696,localport=62002]
        14:17:46 INFO  Started NetworkChannel to
reliable:tcp://PRESLUXWISPSP16:62002

If I start only one broker, I can succesfully send/receive messages to a
topic using the consumer/producer pair found in /activemq-3.0/example,
configured to use Zeroconf (ie. the running broker can be on a remote
machine, it works perfectly).
 
If I start both nodes, things go really bad on the broker where the
client randomly connects through ZeroConf:

        14:18:30 WARN  caught exception consuming packet: SESSION_INFO:
id = 3 SessionInfo{ clientId =
'ID:PRESLUXWISPSP21-1862-1118924263129-5:0' ,
         sessionId = '1' , startTime = 1118924310065, started = true }
        java.lang.IllegalArgumentException: Broker name cannot be empty
or null
                at
org.activemq.message.AbstractPacket.addBrokerVisited(AbstractPacket.java
:173)
                at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
296)
                at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChanne
l.java:143)
                at
org.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:
956)
                at
org.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:
935)
                at
org.activemq.ActiveMQConnection.addSession(ActiveMQConnection.java:1094)
                at
org.activemq.ActiveMQSession.<init>(ActiveMQSession.java:222)
                at
org.activemq.ActiveMQSession.<init>(ActiveMQSession.java:197)
                at
org.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:37
1)
                at
org.activemq.transport.NetworkChannel.createBridge(NetworkChannel.java:4
15)
                at
org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
a:385)
                at
org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
a:379)
                at
org.activemq.transport.NetworkChannel.onConsumerInfo(NetworkChannel.java
:222)
                at
org.activemq.broker.impl.DefaultBroker.fireConsumerInfo(DefaultBroker.ja
va:710)
                at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.
java:256)
                at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(Bro
kerContainerImpl.java:355)
                at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(Bro
kerConnectorImpl.java:170)
                at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClie
ntImpl.java:466)
                at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
327)
                at
org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
ChannelSupport.java:374)
                at
org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
ChannelSupport.java:368)
                at
org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.j
ava:310)
                at java.lang.Thread.run(Thread.java:534)
        14:18:30 WARN  caught exception consuming packet: PRODUCER_INFO:
id = 4 ProducerInfo{ clientId =
'ID:PRESLUXWISPSP21-1862-1118924263129-5:0'
         , destination = null, producerId = '1' , sessionId = '1' ,
startTime = 1118924310096, started = true }
        java.lang.IllegalArgumentException: Broker name cannot be empty
or null
                at
org.activemq.message.AbstractPacket.addBrokerVisited(AbstractPacket.java
:173)
                at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
296)
                at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChanne
l.java:143)
                at
org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChan
nelSupport.java:433)
                at
org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(Tran
sportChannelSupport.java:160)
                at
org.activemq.transport.TransportChannelSupport.send(TransportChannelSupp
ort.java:145)
                at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
82)
                at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
67)
                at
org.activemq.ActiveMQSession.addProducer(ActiveMQSession.java:1272)
                at
org.activemq.ActiveMQMessageProducer.<init>(ActiveMQMessageProducer.java
:94)
                at
org.activemq.ActiveMQSession.createProducer(ActiveMQSession.java:615)
                at
org.activemq.transport.NetworkMessageBridge.start(NetworkMessageBridge.j
ava:155)
                at
org.activemq.transport.NetworkChannel.createBridge(NetworkChannel.java:4
18)
                at
org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
a:385)
                at
org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
a:379)
                at
org.activemq.transport.NetworkChannel.onConsumerInfo(NetworkChannel.java
:222)
                at
org.activemq.broker.impl.DefaultBroker.fireConsumerInfo(DefaultBroker.ja
va:710)
                at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.
java:256)
                at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(Bro
kerContainerImpl.java:355)
                at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(Bro
kerConnectorImpl.java:170)
                at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClie
ntImpl.java:466)
                at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
327)
                at
org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
ChannelSupport.java:374)
                at
org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
ChannelSupport.java:368)
                at
org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.j
ava:310)
                at java.lang.Thread.run(Thread.java:534)
        14:18:30 ERROR Failed to start NetworkMessageBridge for
destination: TEST.FOO
        javax.jms.JMSException: Broker name cannot be empty or null
                at
org.activemq.util.JMSExceptionHelper.newJMSException(JMSExceptionHelper.
java:49)
                at
org.activemq.util.JMSExceptionHelper.newJMSException(JMSExceptionHelper.
java:37)
                at
org.activemq.util.JMSExceptionHelper.newJMSException(JMSExceptionHelper.
java:60)
                at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
87)
                at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
67)
                at
org.activemq.ActiveMQSession.addProducer(ActiveMQSession.java:1272)
                at
org.activemq.ActiveMQMessageProducer.<init>(ActiveMQMessageProducer.java
:94)
                at
org.activemq.ActiveMQSession.createProducer(ActiveMQSession.java:615)
                at
org.activemq.transport.NetworkMessageBridge.start(NetworkMessageBridge.j
ava:155)
                at
org.activemq.transport.NetworkChannel.createBridge(NetworkChannel.java:4
18)
                at
org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
a:385)
                at
org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
a:379)
                at
org.activemq.transport.NetworkChannel.onConsumerInfo(NetworkChannel.java
:222)
                at
org.activemq.broker.impl.DefaultBroker.fireConsumerInfo(DefaultBroker.ja
va:710)
                at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.
java:256)
                at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(Bro
kerContainerImpl.java:355)
                at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(Bro
kerConnectorImpl.java:170)
                at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClie
ntImpl.java:466)
                at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
327)
                at
org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
ChannelSupport.java:374)
                at
org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
ChannelSupport.java:368)
                at
org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.j
ava:310)
                at java.lang.Thread.run(Thread.java:534)
        Caused by: java.lang.IllegalArgumentException: Broker name
cannot be empty or null
                at
org.activemq.message.AbstractPacket.addBrokerVisited(AbstractPacket.java
:173)
                at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
296)
                at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChanne
l.java:143)
                at
org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChan
nelSupport.java:433)
                at
org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(Tran
sportChannelSupport.java:160)
                at
org.activemq.transport.TransportChannelSupport.send(TransportChannelSupp
ort.java:145)
                at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
82)
                ... 19 more

Thanks for any pointer,
David
 
 
 
 
 
 
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: [activemq-user] Configuring Network Of Brokers

Ramzi Saba
David,  use activemq-3.1-M2 from
http://dist.codehaus.org/activemq/distributions/ and your configuration
should work fine.


DOSSOT David wrote:

>Hi all,
>
>Despite real efforts to RTFMs, I have troubles with the configuration of
>a network of standalone brokers, using ZeronConf for the discovery.
>
>I have two brokers on two different machines, Alpha and Beta, both
>configured the same way:
>
> <broker name="Alpha">
>  <connector>
>   <tcpServerTransport uri="tcp://localhost:62002"/>
>  </connector>
>  <discoveryAgent>
>   <zeroconfDiscovery type="_activemq.broker.development."/>
>  </discoveryAgent>
>  <discoveryNetworkConnector/>
>  <persistence>
>   <vmPersistence/>
>  </persistence>
> </broker>
>
>When starting the brokers, I can see them discover each other:
>
> ActiveMQ Message Broker
>
> Loading Mesaage Broker from activemq.xml on the CLASSPATH
> 14:17:44 INFO  ActiveMQ 3.0 JMS Message Broker (Alpha) is
>starting
> 14:17:44 INFO  For help or more information please see:
>www.protique.com <http://www.protique.com>
> 14:17:44 INFO  Listening for connections at:
>tcp://PRESLUXWISPSP21:62002
> 14:17:44 INFO  ActiveMQ connector started:
>TcpTransportServerChannel@tcp://PRESLUXWISPSP21:62002
><mailto:TcpTransportServerChannel@tcp://PRESLUXWISPSP21:62002>
> 14:17:44 INFO  Discovering service of type:
>_activemq.broker.development.
> 14:17:44 INFO  Alpha: Adding new NeworkChannel on:
>reliable:tcp://PRESLUXWISPSP16:62002{resolved=reliable:tcp://PRESLUXWISP
>SP16:62002} with
> details: {connectURL=reliable:tcp://PRESLUXWISPSP16:62002,
>brokerName=Beta}
> 14:17:44 INFO  Listening for connections at: vm://Alpha
> 14:17:44 INFO  ActiveMQ connector started:
>VmTransportServerChannel@vm://Alpha
><mailto:VmTransportServerChannel@vm://Alpha>
> 14:17:44 INFO  Embedded JMS Broker has started
> 14:17:45 INFO  ActiveMQ JMS Message Broker (Alpha) has started
> 14:17:46 INFO  Adding new client:
>ID:PRESLUXWISPSP21-1862-1118924263129-5:0 on transport:
>VmTransportChannel: null
> 14:17:46 INFO  channel status changed: Channel:
>ReliableTransportChannel: TcpTransportChannel:
>Socket[addr=presluxwispsp16/136.173.11.37,port=62002,localport=1863] has
>connected
> 14:17:46 INFO  Adding new client: Beta_NetworkChannel on
>transport: TcpTransportChannel:
>Socket[addr=/136.173.11.37,port=1696,localport=62002]
> 14:17:46 INFO  Started NetworkChannel to
>reliable:tcp://PRESLUXWISPSP16:62002
>
>If I start only one broker, I can succesfully send/receive messages to a
>topic using the consumer/producer pair found in /activemq-3.0/example,
>configured to use Zeroconf (ie. the running broker can be on a remote
>machine, it works perfectly).
>
>If I start both nodes, things go really bad on the broker where the
>client randomly connects through ZeroConf:
>
> 14:18:30 WARN  caught exception consuming packet: SESSION_INFO:
>id = 3 SessionInfo{ clientId =
>'ID:PRESLUXWISPSP21-1862-1118924263129-5:0' ,
> sessionId = '1' , startTime = 1118924310065, started = true }
> java.lang.IllegalArgumentException: Broker name cannot be empty
>or null
>        at
>org.activemq.message.AbstractPacket.addBrokerVisited(AbstractPacket.java
>:173)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
>296)
>        at
>org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChanne
>l.java:143)
>        at
>org.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:
>956)
>        at
>org.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:
>935)
>        at
>org.activemq.ActiveMQConnection.addSession(ActiveMQConnection.java:1094)
>        at
>org.activemq.ActiveMQSession.<init>(ActiveMQSession.java:222)
>        at
>org.activemq.ActiveMQSession.<init>(ActiveMQSession.java:197)
>        at
>org.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:37
>1)
>        at
>org.activemq.transport.NetworkChannel.createBridge(NetworkChannel.java:4
>15)
>        at
>org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
>a:385)
>        at
>org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
>a:379)
>        at
>org.activemq.transport.NetworkChannel.onConsumerInfo(NetworkChannel.java
>:222)
>        at
>org.activemq.broker.impl.DefaultBroker.fireConsumerInfo(DefaultBroker.ja
>va:710)
>        at
>org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.
>java:256)
>        at
>org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(Bro
>kerContainerImpl.java:355)
>        at
>org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(Bro
>kerConnectorImpl.java:170)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClie
>ntImpl.java:466)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
>327)
>        at
>org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
>ChannelSupport.java:374)
>        at
>org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
>ChannelSupport.java:368)
>        at
>org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.j
>ava:310)
>        at java.lang.Thread.run(Thread.java:534)
> 14:18:30 WARN  caught exception consuming packet: PRODUCER_INFO:
>id = 4 ProducerInfo{ clientId =
>'ID:PRESLUXWISPSP21-1862-1118924263129-5:0'
> , destination = null, producerId = '1' , sessionId = '1' ,
>startTime = 1118924310096, started = true }
> java.lang.IllegalArgumentException: Broker name cannot be empty
>or null
>        at
>org.activemq.message.AbstractPacket.addBrokerVisited(AbstractPacket.java
>:173)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
>296)
>        at
>org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChanne
>l.java:143)
>        at
>org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChan
>nelSupport.java:433)
>        at
>org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(Tran
>sportChannelSupport.java:160)
>        at
>org.activemq.transport.TransportChannelSupport.send(TransportChannelSupp
>ort.java:145)
>        at
>org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
>82)
>        at
>org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
>67)
>        at
>org.activemq.ActiveMQSession.addProducer(ActiveMQSession.java:1272)
>        at
>org.activemq.ActiveMQMessageProducer.<init>(ActiveMQMessageProducer.java
>:94)
>        at
>org.activemq.ActiveMQSession.createProducer(ActiveMQSession.java:615)
>        at
>org.activemq.transport.NetworkMessageBridge.start(NetworkMessageBridge.j
>ava:155)
>        at
>org.activemq.transport.NetworkChannel.createBridge(NetworkChannel.java:4
>18)
>        at
>org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
>a:385)
>        at
>org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
>a:379)
>        at
>org.activemq.transport.NetworkChannel.onConsumerInfo(NetworkChannel.java
>:222)
>        at
>org.activemq.broker.impl.DefaultBroker.fireConsumerInfo(DefaultBroker.ja
>va:710)
>        at
>org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.
>java:256)
>        at
>org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(Bro
>kerContainerImpl.java:355)
>        at
>org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(Bro
>kerConnectorImpl.java:170)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClie
>ntImpl.java:466)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
>327)
>        at
>org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
>ChannelSupport.java:374)
>        at
>org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
>ChannelSupport.java:368)
>        at
>org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.j
>ava:310)
>        at java.lang.Thread.run(Thread.java:534)
> 14:18:30 ERROR Failed to start NetworkMessageBridge for
>destination: TEST.FOO
> javax.jms.JMSException: Broker name cannot be empty or null
>        at
>org.activemq.util.JMSExceptionHelper.newJMSException(JMSExceptionHelper.
>java:49)
>        at
>org.activemq.util.JMSExceptionHelper.newJMSException(JMSExceptionHelper.
>java:37)
>        at
>org.activemq.util.JMSExceptionHelper.newJMSException(JMSExceptionHelper.
>java:60)
>        at
>org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
>87)
>        at
>org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
>67)
>        at
>org.activemq.ActiveMQSession.addProducer(ActiveMQSession.java:1272)
>        at
>org.activemq.ActiveMQMessageProducer.<init>(ActiveMQMessageProducer.java
>:94)
>        at
>org.activemq.ActiveMQSession.createProducer(ActiveMQSession.java:615)
>        at
>org.activemq.transport.NetworkMessageBridge.start(NetworkMessageBridge.j
>ava:155)
>        at
>org.activemq.transport.NetworkChannel.createBridge(NetworkChannel.java:4
>18)
>        at
>org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
>a:385)
>        at
>org.activemq.transport.NetworkChannel.addConsumerInfo(NetworkChannel.jav
>a:379)
>        at
>org.activemq.transport.NetworkChannel.onConsumerInfo(NetworkChannel.java
>:222)
>        at
>org.activemq.broker.impl.DefaultBroker.fireConsumerInfo(DefaultBroker.ja
>va:710)
>        at
>org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.
>java:256)
>        at
>org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(Bro
>kerContainerImpl.java:355)
>        at
>org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(Bro
>kerConnectorImpl.java:170)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClie
>ntImpl.java:466)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
>327)
>        at
>org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
>ChannelSupport.java:374)
>        at
>org.activemq.transport.TransportChannelSupport.doConsumePacket(Transport
>ChannelSupport.java:368)
>        at
>org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.j
>ava:310)
>        at java.lang.Thread.run(Thread.java:534)
> Caused by: java.lang.IllegalArgumentException: Broker name
>cannot be empty or null
>        at
>org.activemq.message.AbstractPacket.addBrokerVisited(AbstractPacket.java
>:173)
>        at
>org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:
>296)
>        at
>org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChanne
>l.java:143)
>        at
>org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChan
>nelSupport.java:433)
>        at
>org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(Tran
>sportChannelSupport.java:160)
>        at
>org.activemq.transport.TransportChannelSupport.send(TransportChannelSupp
>ort.java:145)
>        at
>org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:9
>82)
>        ... 19 more
>
>Thanks for any pointer,
>David
>
>
>
>
>
>
>
>  
>

--
Ramzi Saba
Optaros, Inc - www.optaros.com

Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

RE: [activemq-user] Configuring Network Of Brokers

DOSSOT David
In reply to this post by DOSSOT David
Ramzi, I works perfectly on M2. Great stuff! Thanks.
 

-----Original Message-----
From: Ramzi Saba [mailto:[hidden email]]
Sent: 16 June 2005 14:43
To: [hidden email]
Subject: Re: [activemq-user] Configuring Network Of Brokers

David,  use activemq-3.1-M2 from
http://dist.codehaus.org/activemq/distributions/ and your configuration
should work fine.

Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

[activemq-user] Switching to 'Persistent' kills ActiveMQ

James Butler
In reply to this post by DOSSOT David
Hi all,

I was using ActiveMQ 2.1 in its out of the box configuration. I had
configured a topic publisher with persistence set to false. This has
been working ok for some time though whenever I get send message, the
broker warns that it couldn't find a matching message for identity BLAH.

Anyhoo, I turned on the persistence option and now the broker crashes on
startup:

ActiveMQ Message Broker

Loading Mesaage Broker from activemq.xml on the CLASSPATH
16:32:30 INFO  ActiveMQ 2.1 JMS Message Broker
(ID:tester04-01-4378-111893594
9688-0:0) is starting
16:32:30 INFO  For help or more information please see: www.protique.com
16:32:32 WARN  Could not create JDBC tables; they could already exist.
Failure w
as: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT NULL, CONTAINER
VARCHAR(250), MSGI
D VARCHAR(250), MSG BLOB, PRIMARY KEY ( ID ) ) Message: Table/View
'ACTIVEMQ_MSG
S' already exists in Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
16:32:33 WARN  Could not create JDBC tables; they could already exist.
Failure w
as: CREATE TABLE ACTIVEMQ_TXS(XID VARCHAR(250) NOT NULL, PRIMARY KEY (
XID )) Me
ssage: Table/View 'ACTIVEMQ_TXS' already exists in Schema 'APP'.
SQLState: X0Y32
 Vendor code: 20000
16:32:33 WARN  Could not create JDBC tables; they could already exist.
Failure w
as: CREATE TABLE ACTIVEMQ_ACKS(SUB VARCHAR(250) NOT NULL, CONTAINER
VARCHAR(250)
 NOT NULL, LAST_ACKED_ID INTEGER, SE_ID INTEGER, SE_CLIENT_ID
VARCHAR(250), SE_C
ONSUMER_NAME VARCHAR(250), SE_SELECTOR VARCHAR(250), PRIMARY KEY ( SUB,
CONTAINE
R )) Message: Table/View 'ACTIVEMQ_ACKS' already exists in Schema 'APP'.
SQLStat
e: X0Y32 Vendor code: 20000
16:32:34 INFO  Opening journal.
16:32:34 INFO  Opened journal: Active Journal: using 4 x 10.0 Megs at:
..\var\jo
urnal
16:32:34 INFO  Journal Recovery Started.
Caught: javax.jms.JMSException: Failed to recover transactions from
journal: jav
a.lang.NullPointerException
javax.jms.JMSException: Failed to recover transactions from journal:
java.lang.N
ullPointerException
        at
org.codehaus.activemq.util.JMSExceptionHelper.newJMSException(JMSExce
ptionHelper.java:49)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
ournalPersistenceAdapter.java:188)
        at
org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
PersistenceAdapter.java:85)
        at
org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
ava:148)
        at
org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
tainerImpl.java:147)
        at org.codehaus.activemq.spring.Main.main(Main.java:72)
Caused by: java.lang.NullPointerException
        at
EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
e)
        at
EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
opicMessageStore(JournalPersistenceAdapter.java:142)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
essageStore(JournalPersistenceAdapter.java:127)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
(JournalPersistenceAdapter.java:586)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
ournalPersistenceAdapter.java:185)
        ... 4 more
Reason: java.lang.NullPointerException
java.lang.NullPointerException
        at
EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
e)
        at
EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
opicMessageStore(JournalPersistenceAdapter.java:142)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
essageStore(JournalPersistenceAdapter.java:127)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
(JournalPersistenceAdapter.java:586)
        at
org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
ournalPersistenceAdapter.java:185)
        at
org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
PersistenceAdapter.java:85)
        at
org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
ava:148)
        at
org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
tainerImpl.java:147)
        at org.codehaus.activemq.spring.Main.main(Main.java:72)

I think my db tables have been screwed up somehow??

Any ideas?

Cheers,

Jim


********************************************************

This email message is for the sole use of the intended recipient(s) and
may contain confidential and/or privileged information. Any unauthorized
review, use, disclosure, printing, copying or distribution is
prohibited.  If you are not, or believe you are not, the intended
recipient, please contact our systems administrator immediately at
[hidden email] and destroy all copies of the original message and
any attachments.

Any views or opinions presented are solely those of the author and do
not necessarily represent those of QUMAS.

QUMAS has a virus detection policy but cannot accept responsibility for
any loss or damage arising from the opening or use of this email and/or
attachments.
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: [activemq-user] Switching to 'Persistent' kills ActiveMQ

chirino
Switch to 3.0 or 3.1-M2.  That problem has been fixed.

Regards,
Hiram


On Jun 16, 2005, at 11:37 AM, James Butler wrote:

> Hi all,
>
> I was using ActiveMQ 2.1 in its out of the box configuration. I had
> configured a topic publisher with persistence set to false. This has
> been working ok for some time though whenever I get send message, the
> broker warns that it couldn't find a matching message for identity  
> BLAH.
>
> Anyhoo, I turned on the persistence option and now the broker  
> crashes on
> startup:
>
> ActiveMQ Message Broker
>
> Loading Mesaage Broker from activemq.xml on the CLASSPATH
> 16:32:30 INFO  ActiveMQ 2.1 JMS Message Broker
> (ID:tester04-01-4378-111893594
> 9688-0:0) is starting
> 16:32:30 INFO  For help or more information please see:  
> www.protique.com
> 16:32:32 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT NULL, CONTAINER
> VARCHAR(250), MSGI
> D VARCHAR(250), MSG BLOB, PRIMARY KEY ( ID ) ) Message: Table/View
> 'ACTIVEMQ_MSG
> S' already exists in Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
> 16:32:33 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_TXS(XID VARCHAR(250) NOT NULL, PRIMARY KEY (
> XID )) Me
> ssage: Table/View 'ACTIVEMQ_TXS' already exists in Schema 'APP'.
> SQLState: X0Y32
>  Vendor code: 20000
> 16:32:33 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_ACKS(SUB VARCHAR(250) NOT NULL, CONTAINER
> VARCHAR(250)
>  NOT NULL, LAST_ACKED_ID INTEGER, SE_ID INTEGER, SE_CLIENT_ID
> VARCHAR(250), SE_C
> ONSUMER_NAME VARCHAR(250), SE_SELECTOR VARCHAR(250), PRIMARY KEY  
> ( SUB,
> CONTAINE
> R )) Message: Table/View 'ACTIVEMQ_ACKS' already exists in Schema  
> 'APP'.
> SQLStat
> e: X0Y32 Vendor code: 20000
> 16:32:34 INFO  Opening journal.
> 16:32:34 INFO  Opened journal: Active Journal: using 4 x 10.0 Megs at:
> ..\var\jo
> urnal
> 16:32:34 INFO  Journal Recovery Started.
> Caught: javax.jms.JMSException: Failed to recover transactions from
> journal: jav
> a.lang.NullPointerException
> javax.jms.JMSException: Failed to recover transactions from journal:
> java.lang.N
> ullPointerException
>         at
> org.codehaus.activemq.util.JMSExceptionHelper.newJMSException(JMSExce
> ptionHelper.java:49)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
> ournalPersistenceAdapter.java:188)
>         at
> org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
> PersistenceAdapter.java:85)
>         at
> org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
> ava:148)
>         at
> org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
> tainerImpl.java:147)
>         at org.codehaus.activemq.spring.Main.main(Main.java:72)
> Caused by: java.lang.NullPointerException
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
> e)
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
> )
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
> opicMessageStore(JournalPersistenceAdapter.java:142)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
> essageStore(JournalPersistenceAdapter.java:127)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
> (JournalPersistenceAdapter.java:586)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
> ournalPersistenceAdapter.java:185)
>         ... 4 more
> Reason: java.lang.NullPointerException
> java.lang.NullPointerException
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
> e)
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
> )
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
> opicMessageStore(JournalPersistenceAdapter.java:142)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
> essageStore(JournalPersistenceAdapter.java:127)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
> (JournalPersistenceAdapter.java:586)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
> ournalPersistenceAdapter.java:185)
>         at
> org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
> PersistenceAdapter.java:85)
>         at
> org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
> ava:148)
>         at
> org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
> tainerImpl.java:147)
>         at org.codehaus.activemq.spring.Main.main(Main.java:72)
>
> I think my db tables have been screwed up somehow??
>
> Any ideas?
>
> Cheers,
>
> Jim
>
>
> ********************************************************
>
> This email message is for the sole use of the intended recipient(s)  
> and
> may contain confidential and/or privileged information. Any  
> unauthorized
> review, use, disclosure, printing, copying or distribution is
> prohibited.  If you are not, or believe you are not, the intended
> recipient, please contact our systems administrator immediately at
> [hidden email] and destroy all copies of the original message  
> and
> any attachments.
>
> Any views or opinions presented are solely those of the author and do
> not necessarily represent those of QUMAS.
>
> QUMAS has a virus detection policy but cannot accept responsibility  
> for
> any loss or damage arising from the opening or use of this email  
> and/or
> attachments.
>

Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

RE: [activemq-user] Switching to 'Persistent' kills ActiveMQ

James Butler
In reply to this post by James Butler
Hi Hiram,

thanks for the quick reply!

I just installed 3.0.. I used the same producer and received the
following error:

C:\activemq-3.0\bin>activemq
ActiveMQ Message Broker

Loading Mesaage Broker from activemq.xml on the CLASSPATH
16:48:48 INFO  ActiveMQ 3.0 JMS Message Broker
(ID:tester04-01-4482-111893692
7769-0:0) is starting
16:48:48 INFO  For help or more information please see: www.protique.com
16:48:52 INFO  Database driver recognized:
[apache_derby_embedded_jdbc_driver]
16:48:53 WARN  Could not create JDBC tables; they could already exist.
Failure w
as: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT NULL, CONTAINER
VARCHAR(250), MSGI
D VARCHAR(250), MSG BLOB, PRIMARY KEY ( ID ) ) Message: Table/View
'ACTIVEMQ_MSG
S' already exists in Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
16:48:53 WARN  Could not create JDBC tables; they could already exist.
Failure w
as: CREATE TABLE ACTIVEMQ_TXS(XID VARCHAR(250) NOT NULL, PRIMARY KEY (
XID )) Me
ssage: Table/View 'ACTIVEMQ_TXS' already exists in Schema 'APP'.
SQLState: X0Y32
 Vendor code: 20000
16:48:54 WARN  Could not create JDBC tables; they could already exist.
Failure w
as: CREATE TABLE ACTIVEMQ_ACKS(SUB VARCHAR(250) NOT NULL, CONTAINER
VARCHAR(250)
 NOT NULL, LAST_ACKED_ID INTEGER, SE_ID INTEGER, SE_CLIENT_ID
VARCHAR(250), SE_C
ONSUMER_NAME VARCHAR(250), SE_SELECTOR VARCHAR(250), PRIMARY KEY ( SUB,
CONTAINE
R )) Message: Table/View 'ACTIVEMQ_ACKS' already exists in Schema 'APP'.
SQLStat
e: X0Y32 Vendor code: 20000
16:48:54 INFO  Opening journal.
16:48:54 INFO  Opened journal: Active Journal: using 2 x 20.0 Megs at:
..\var\jo
urnal
16:48:54 INFO  Journal Recovery Started.
16:48:54 INFO  Journal Recovered: 0 message(s) in transactions
recovered.
16:48:54 INFO  Listening for connections at: tcp://Qwstester04-01:61616
16:48:54 INFO  ActiveMQ connector started:
TcpTransportServerChannel@tcp://Qwste
ster04-01:61616
16:48:54 INFO  ActiveMQ JMS Message Broker
(ID:Qwstester04-01-4482-1118936927769
-0:0) has started
16:49:11 INFO  Adding new client:
ID:Qwstester04-01-4483-1118936950410-2:0 on tr
ansport: TcpTransportChannel:
Socket[addr=/127.0.0.1,port=4484,localport=61616]
java.lang.ClassCastException
        at
org.activemq.message.ActiveMQMessage.setJMSDestination(ActiveMQMessag
e.java:1266)
        at
org.activemq.io.impl.ActiveMQMessageReader.buildPacket(ActiveMQMessag
eReader.java:106)
        at
org.activemq.io.impl.DefaultWireFormat.readPacket(DefaultWireFormat.j
ava:129)
        at
org.activemq.io.impl.AbstractDefaultWireFormat.readPacket(AbstractDef
aultWireFormat.java:189)
        at
org.activemq.io.impl.AbstractDefaultWireFormat.readPacket(AbstractDef
aultWireFormat.java:174)
        at
org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChanne
l.java:308)
        at java.lang.Thread.run(Thread.java:534)

Any ideas?

Cheers,

Jim

-----Original Message-----
From: Hiram Chirino [mailto:[hidden email]]
Sent: 16 June 2005 16:58
To: [hidden email]
Subject: Re: [activemq-user] Switching to 'Persistent' kills ActiveMQ


Switch to 3.0 or 3.1-M2.  That problem has been fixed.

Regards,
Hiram


On Jun 16, 2005, at 11:37 AM, James Butler wrote:

> Hi all,
>
> I was using ActiveMQ 2.1 in its out of the box configuration. I had
> configured a topic publisher with persistence set to false. This has
> been working ok for some time though whenever I get send message, the
> broker warns that it couldn't find a matching message for identity  
> BLAH.
>
> Anyhoo, I turned on the persistence option and now the broker  
> crashes on
> startup:
>
> ActiveMQ Message Broker
>
> Loading Mesaage Broker from activemq.xml on the CLASSPATH
> 16:32:30 INFO  ActiveMQ 2.1 JMS Message Broker
> (ID:tester04-01-4378-111893594
> 9688-0:0) is starting
> 16:32:30 INFO  For help or more information please see:  
> www.protique.com
> 16:32:32 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT NULL, CONTAINER
> VARCHAR(250), MSGI
> D VARCHAR(250), MSG BLOB, PRIMARY KEY ( ID ) ) Message: Table/View
> 'ACTIVEMQ_MSG
> S' already exists in Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
> 16:32:33 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_TXS(XID VARCHAR(250) NOT NULL, PRIMARY KEY (
> XID )) Me
> ssage: Table/View 'ACTIVEMQ_TXS' already exists in Schema 'APP'.
> SQLState: X0Y32
>  Vendor code: 20000
> 16:32:33 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_ACKS(SUB VARCHAR(250) NOT NULL, CONTAINER
> VARCHAR(250)
>  NOT NULL, LAST_ACKED_ID INTEGER, SE_ID INTEGER, SE_CLIENT_ID
> VARCHAR(250), SE_C
> ONSUMER_NAME VARCHAR(250), SE_SELECTOR VARCHAR(250), PRIMARY KEY  
> ( SUB,
> CONTAINE
> R )) Message: Table/View 'ACTIVEMQ_ACKS' already exists in Schema  
> 'APP'.
> SQLStat
> e: X0Y32 Vendor code: 20000
> 16:32:34 INFO  Opening journal.
> 16:32:34 INFO  Opened journal: Active Journal: using 4 x 10.0 Megs at:
> ..\var\jo
> urnal
> 16:32:34 INFO  Journal Recovery Started.
> Caught: javax.jms.JMSException: Failed to recover transactions from
> journal: jav
> a.lang.NullPointerException
> javax.jms.JMSException: Failed to recover transactions from journal:
> java.lang.N
> ullPointerException
>         at
> org.codehaus.activemq.util.JMSExceptionHelper.newJMSException(JMSExce
> ptionHelper.java:49)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
> ournalPersistenceAdapter.java:188)
>         at
> org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
> PersistenceAdapter.java:85)
>         at
> org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
> ava:148)
>         at
> org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
> tainerImpl.java:147)
>         at org.codehaus.activemq.spring.Main.main(Main.java:72)
> Caused by: java.lang.NullPointerException
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
> e)
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
> )
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
> opicMessageStore(JournalPersistenceAdapter.java:142)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
> essageStore(JournalPersistenceAdapter.java:127)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
> (JournalPersistenceAdapter.java:586)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
> ournalPersistenceAdapter.java:185)
>         ... 4 more
> Reason: java.lang.NullPointerException
> java.lang.NullPointerException
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
> e)
>         at
> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
> )
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
> opicMessageStore(JournalPersistenceAdapter.java:142)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
> essageStore(JournalPersistenceAdapter.java:127)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
> (JournalPersistenceAdapter.java:586)
>         at
> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
> ournalPersistenceAdapter.java:185)
>         at
> org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
> PersistenceAdapter.java:85)
>         at
> org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
> ava:148)
>         at
> org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
> tainerImpl.java:147)
>         at org.codehaus.activemq.spring.Main.main(Main.java:72)
>
> I think my db tables have been screwed up somehow??
>
> Any ideas?
>
> Cheers,
>
> Jim
>
>
> ********************************************************
>
> This email message is for the sole use of the intended recipient(s)  
> and
> may contain confidential and/or privileged information. Any  
> unauthorized
> review, use, disclosure, printing, copying or distribution is
> prohibited.  If you are not, or believe you are not, the intended
> recipient, please contact our systems administrator immediately at
> [hidden email] and destroy all copies of the original message  
> and
> any attachments.
>
> Any views or opinions presented are solely those of the author and do
> not necessarily represent those of QUMAS.
>
> QUMAS has a virus detection policy but cannot accept responsibility  
> for
> any loss or damage arising from the opening or use of this email  
> and/or
> attachments.
>


********************************************************

This email message is for the sole use of the intended recipient(s) and
may contain confidential and/or privileged information. Any unauthorized
review, use, disclosure, printing, copying or distribution is
prohibited.  If you are not, or believe you are not, the intended
recipient, please contact our systems administrator immediately at
[hidden email] and destroy all copies of the original message and
any attachments.

Any views or opinions presented are solely those of the author and do
not necessarily represent those of QUMAS.

QUMAS has a virus detection policy but cannot accept responsibility for
any loss or damage arising from the opening or use of this email and/or
attachments.
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: [activemq-user] Switching to 'Persistent' kills ActiveMQ

chirino
Make sure all clients are using the new 3.x libraries.

Regards,
Hiram

On Jun 16, 2005, at 12:03 PM, James Butler wrote:

> Hi Hiram,
>
> thanks for the quick reply!
>
> I just installed 3.0.. I used the same producer and received the
> following error:
>
> C:\activemq-3.0\bin>activemq
> ActiveMQ Message Broker
>
> Loading Mesaage Broker from activemq.xml on the CLASSPATH
> 16:48:48 INFO  ActiveMQ 3.0 JMS Message Broker
> (ID:tester04-01-4482-111893692
> 7769-0:0) is starting
> 16:48:48 INFO  For help or more information please see:  
> www.protique.com
> 16:48:52 INFO  Database driver recognized:
> [apache_derby_embedded_jdbc_driver]
> 16:48:53 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT NULL, CONTAINER
> VARCHAR(250), MSGI
> D VARCHAR(250), MSG BLOB, PRIMARY KEY ( ID ) ) Message: Table/View
> 'ACTIVEMQ_MSG
> S' already exists in Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
> 16:48:53 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_TXS(XID VARCHAR(250) NOT NULL, PRIMARY KEY (
> XID )) Me
> ssage: Table/View 'ACTIVEMQ_TXS' already exists in Schema 'APP'.
> SQLState: X0Y32
>  Vendor code: 20000
> 16:48:54 WARN  Could not create JDBC tables; they could already exist.
> Failure w
> as: CREATE TABLE ACTIVEMQ_ACKS(SUB VARCHAR(250) NOT NULL, CONTAINER
> VARCHAR(250)
>  NOT NULL, LAST_ACKED_ID INTEGER, SE_ID INTEGER, SE_CLIENT_ID
> VARCHAR(250), SE_C
> ONSUMER_NAME VARCHAR(250), SE_SELECTOR VARCHAR(250), PRIMARY KEY  
> ( SUB,
> CONTAINE
> R )) Message: Table/View 'ACTIVEMQ_ACKS' already exists in Schema  
> 'APP'.
> SQLStat
> e: X0Y32 Vendor code: 20000
> 16:48:54 INFO  Opening journal.
> 16:48:54 INFO  Opened journal: Active Journal: using 2 x 20.0 Megs at:
> ..\var\jo
> urnal
> 16:48:54 INFO  Journal Recovery Started.
> 16:48:54 INFO  Journal Recovered: 0 message(s) in transactions
> recovered.
> 16:48:54 INFO  Listening for connections at: tcp://
> Qwstester04-01:61616
> 16:48:54 INFO  ActiveMQ connector started:
> TcpTransportServerChannel@tcp://Qwste
> ster04-01:61616
> 16:48:54 INFO  ActiveMQ JMS Message Broker
> (ID:Qwstester04-01-4482-1118936927769
> -0:0) has started
> 16:49:11 INFO  Adding new client:
> ID:Qwstester04-01-4483-1118936950410-2:0 on tr
> ansport: TcpTransportChannel:
> Socket[addr=/127.0.0.1,port=4484,localport=61616]
> java.lang.ClassCastException
>         at
> org.activemq.message.ActiveMQMessage.setJMSDestination(ActiveMQMessag
> e.java:1266)
>         at
> org.activemq.io.impl.ActiveMQMessageReader.buildPacket(ActiveMQMessag
> eReader.java:106)
>         at
> org.activemq.io.impl.DefaultWireFormat.readPacket(DefaultWireFormat.j
> ava:129)
>         at
> org.activemq.io.impl.AbstractDefaultWireFormat.readPacket(AbstractDef
> aultWireFormat.java:189)
>         at
> org.activemq.io.impl.AbstractDefaultWireFormat.readPacket(AbstractDef
> aultWireFormat.java:174)
>         at
> org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChanne
> l.java:308)
>         at java.lang.Thread.run(Thread.java:534)
>
> Any ideas?
>
> Cheers,
>
> Jim
>
> -----Original Message-----
> From: Hiram Chirino [mailto:[hidden email]]
> Sent: 16 June 2005 16:58
> To: [hidden email]
> Subject: Re: [activemq-user] Switching to 'Persistent' kills ActiveMQ
>
>
> Switch to 3.0 or 3.1-M2.  That problem has been fixed.
>
> Regards,
> Hiram
>
>
> On Jun 16, 2005, at 11:37 AM, James Butler wrote:
>
>
>> Hi all,
>>
>> I was using ActiveMQ 2.1 in its out of the box configuration. I had
>> configured a topic publisher with persistence set to false. This has
>> been working ok for some time though whenever I get send message, the
>> broker warns that it couldn't find a matching message for identity
>> BLAH.
>>
>> Anyhoo, I turned on the persistence option and now the broker
>> crashes on
>> startup:
>>
>> ActiveMQ Message Broker
>>
>> Loading Mesaage Broker from activemq.xml on the CLASSPATH
>> 16:32:30 INFO  ActiveMQ 2.1 JMS Message Broker
>> (ID:tester04-01-4378-111893594
>> 9688-0:0) is starting
>> 16:32:30 INFO  For help or more information please see:
>> www.protique.com
>> 16:32:32 WARN  Could not create JDBC tables; they could already  
>> exist.
>> Failure w
>> as: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT NULL, CONTAINER
>> VARCHAR(250), MSGI
>> D VARCHAR(250), MSG BLOB, PRIMARY KEY ( ID ) ) Message: Table/View
>> 'ACTIVEMQ_MSG
>> S' already exists in Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
>> 16:32:33 WARN  Could not create JDBC tables; they could already  
>> exist.
>> Failure w
>> as: CREATE TABLE ACTIVEMQ_TXS(XID VARCHAR(250) NOT NULL, PRIMARY  
>> KEY (
>> XID )) Me
>> ssage: Table/View 'ACTIVEMQ_TXS' already exists in Schema 'APP'.
>> SQLState: X0Y32
>>  Vendor code: 20000
>> 16:32:33 WARN  Could not create JDBC tables; they could already  
>> exist.
>> Failure w
>> as: CREATE TABLE ACTIVEMQ_ACKS(SUB VARCHAR(250) NOT NULL, CONTAINER
>> VARCHAR(250)
>>  NOT NULL, LAST_ACKED_ID INTEGER, SE_ID INTEGER, SE_CLIENT_ID
>> VARCHAR(250), SE_C
>> ONSUMER_NAME VARCHAR(250), SE_SELECTOR VARCHAR(250), PRIMARY KEY
>> ( SUB,
>> CONTAINE
>> R )) Message: Table/View 'ACTIVEMQ_ACKS' already exists in Schema
>> 'APP'.
>> SQLStat
>> e: X0Y32 Vendor code: 20000
>> 16:32:34 INFO  Opening journal.
>> 16:32:34 INFO  Opened journal: Active Journal: using 4 x 10.0 Megs  
>> at:
>> ..\var\jo
>> urnal
>> 16:32:34 INFO  Journal Recovery Started.
>> Caught: javax.jms.JMSException: Failed to recover transactions from
>> journal: jav
>> a.lang.NullPointerException
>> javax.jms.JMSException: Failed to recover transactions from journal:
>> java.lang.N
>> ullPointerException
>>         at
>> org.codehaus.activemq.util.JMSExceptionHelper.newJMSException(JMSExce
>> ptionHelper.java:49)
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
>> ournalPersistenceAdapter.java:188)
>>         at
>> org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
>> PersistenceAdapter.java:85)
>>         at
>> org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
>> ava:148)
>>         at
>> org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
>> tainerImpl.java:147)
>>         at org.codehaus.activemq.spring.Main.main(Main.java:72)
>> Caused by: java.lang.NullPointerException
>>         at
>> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
>> e)
>>         at
>> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
>> )
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
>> opicMessageStore(JournalPersistenceAdapter.java:142)
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
>> essageStore(JournalPersistenceAdapter.java:127)
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
>> (JournalPersistenceAdapter.java:586)
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
>> ournalPersistenceAdapter.java:185)
>>         ... 4 more
>> Reason: java.lang.NullPointerException
>> java.lang.NullPointerException
>>         at
>> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.hash(Unknown Sourc
>> e)
>>         at
>> EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap.get(Unknown Source
>> )
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createT
>> opicMessageStore(JournalPersistenceAdapter.java:142)
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.createM
>> essageStore(JournalPersistenceAdapter.java:127)
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.recover
>> (JournalPersistenceAdapter.java:586)
>>         at
>> org.codehaus.activemq.store.journal.JournalPersistenceAdapter.start(J
>> ournalPersistenceAdapter.java:185)
>>         at
>> org.codehaus.activemq.store.cache.CachePersistenceAdapter.start(Cache
>> PersistenceAdapter.java:85)
>>         at
>> org.codehaus.activemq.broker.impl.DefaultBroker.start(DefaultBroker.j
>> ava:148)
>>         at
>> org.codehaus.activemq.broker.impl.BrokerContainerImpl.start(BrokerCon
>> tainerImpl.java:147)
>>         at org.codehaus.activemq.spring.Main.main(Main.java:72)
>>
>> I think my db tables have been screwed up somehow??
>>
>> Any ideas?
>>
>> Cheers,
>>
>> Jim
>>
>>
>> ********************************************************
>>
>> This email message is for the sole use of the intended recipient(s)
>> and
>> may contain confidential and/or privileged information. Any
>> unauthorized
>> review, use, disclosure, printing, copying or distribution is
>> prohibited.  If you are not, or believe you are not, the intended
>> recipient, please contact our systems administrator immediately at
>> [hidden email] and destroy all copies of the original message
>> and
>> any attachments.
>>
>> Any views or opinions presented are solely those of the author and do
>> not necessarily represent those of QUMAS.
>>
>> QUMAS has a virus detection policy but cannot accept responsibility
>> for
>> any loss or damage arising from the opening or use of this email
>> and/or
>> attachments.
>>
>>
>
>
> ********************************************************
>
> This email message is for the sole use of the intended recipient(s)  
> and
> may contain confidential and/or privileged information. Any  
> unauthorized
> review, use, disclosure, printing, copying or distribution is
> prohibited.  If you are not, or believe you are not, the intended
> recipient, please contact our systems administrator immediately at
> [hidden email] and destroy all copies of the original message  
> and
> any attachments.
>
> Any views or opinions presented are solely those of the author and do
> not necessarily represent those of QUMAS.
>
> QUMAS has a virus detection policy but cannot accept responsibility  
> for
> any loss or damage arising from the opening or use of this email  
> and/or
> attachments.
>

Loading...