activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From flachwassertiroler <martin.radi...@desy.de>
Subject Re: messages don't find their way to consumer
Date Tue, 18 Mar 2008 08:48:12 GMT

Hi James,

thanks for the reply.

Yes, it works if both clients connect to a standalone broker. It even works
if I have 2 standalone-brokers (store-and-forward interconnect), each of
them connected with a client.

So I guess the conf of my embedded broker (programatically configured) is
incorrect. Here again the java snippet, which configures the broker:

-------------------------------------------------------------------------------

       _broker = new BrokerService();
        _broker.setBrokerName(_brokerName);
        //broker.setUseShutdownHook(true);
        
        _broker.setUseJmx(true);
        _broker.setPersistent(false);
        _broker.setClustered(true);
                
        NetworkConnector connector = new
DiscoveryNetworkConnector(_upstreamBrokerURI);
        
        connector.setDuplex(true);
        connector.setNetworkTTL(30);
        connector.setBridgeTempDestinations(true);
        connector.setDynamicOnly(true);
        
        _broker.addNetworkConnector(connector);

        _broker.start();

-------------------------------------------------------------------------------

I need to configure the broker this way (and not via XML), because I don't
know the brokerName at startup-time and loading the broker-config from xml
(xbean) and overwriting the brokername doesn't seem to work.

BTW, I use ActiveMQ 5.0.0 with SUN JDK 1.6

Any help is highly appreciated..

Cheers,
Martin






James.Strachan wrote:
> 
> Does your application work when using a single broker without using
> store & forward networking?
> 
> On 17/03/2008, flachwassertiroler <martin.radicke@desy.de> wrote:
>>
>>  Hi all,
>>
>>  I'm a total newbie to ActiveMQ and JMS in general, so here's my
>> question:
>>
>>  I have a topic publisher and a subscriber. Each of them connects to an
>>  embedded broker, those brokers connect to a central, standalone broker
>>  (using duplex connections), spanning a network of brokers.
>>
>>  I see in the debug of the central broker ("broker1")', that both "leaf"
>>  broker connect and duplex is enabled. Subscriber and Publisher use the
>> same
>>  topic. Unfortunately, the subscriber never gets a single message!
>>
>>  What I observe: When the broker of the subscriber
>> ("LeafBrokerSubscriber")
>>  connects, the central broker receives the consumer request:
>>
>>  Broker1 Forwarding sub on vm://Broker1#28 from LeafBrokerSubscriber :
>>  ConsumerInfo {commandId = 4, responseRequired = true, consumerId =
>>  ID:pcx5211-36658-1205777953152-3:0:1:1, destination =
>>  topic://ActiveMQNewsChannel, prefetchSize = 32766,
>>  maximumPendingMessageLimit = 0, browser = false, dispatchAsync = false,
>>  selector = null, subscriptionName = null, noLocal = false, exclusive =
>>  false, retroactive = false, priority = 0, brokerPath = null,
>>  optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
>>  null}
>>
>>  The publisher also connects to the central broker (via it's embedded
>>  "LeafBrokerPublisher") and sends messages. They are not forwarded to the
>>  consumer, but pile up on the LeafBrokerPublisher (observed with JMX). I
>> also
>>  see through JMX that all 3 brokers have my topic
>> ("ActiveMQNewsChannel").
>>
>>  What am I doing wrong? Please find attached the code snippet of the
>> embedded
>>  broker, the xml conf of the central broker and debug output of the
>>  Publishing client, the subscribing client and the central broker.
>>
>>  Thanks in advance, I'm already a bit desperate!!
>>
>>  Cheers,
>>  Martin
>>
>>  http://www.nabble.com/file/p16098486/emebddedBrokerSnippet
>>  emebddedBrokerSnippet
>>  http://www.nabble.com/file/p16098486/broker1Config.xml broker1Config.xml
>>  http://www.nabble.com/file/p16098486/centralBrokerDebug
>> centralBrokerDebug
>>  http://www.nabble.com/file/p16098486/PublisherDebug PublisherDebug
>>  http://www.nabble.com/file/p16098486/SubscriberDebug SubscriberDebug
>>
>>
>>  --
>>  View this message in context:
>> http://www.nabble.com/messages-don%27t-find-their-way-to-consumer-tp16098486s2354p16098486.html
>>  Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
> 
> 
> -- 
> James
> -------
> http://macstrac.blogspot.com/
> 
> Open Source Integration
> http://open.iona.com
> 
> 

-- 
View this message in context: http://www.nabble.com/messages-don%27t-find-their-way-to-consumer-tp16098486s2354p16116556.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message