Message not forwared in a network broker - ActiveMQ 5.3 & SMX4

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Message not forwared in a network broker - ActiveMQ 5.3 & SMX4

cmoulliard
Hi,

I run ActiveMq 5.3 in embedded mode in two SMX4 instances. I have defined a forward network topology to formard messages from master to slave when a client is connected to the slave. No messages are forwarded ? Where is the issue ?

Config of Master

   <broker xmlns="http://activemq.apache.org/schema/core" dataDirectory="d:/temp/activemq-data" brokerName="master" useShutdownHook="false" useJmx="true" advisorySupport="false">

       
        <destinationPolicy>
            <policyMap>
                <policyEntries>
                    <policyEntry queue=">" memoryLimit="5mb"/>
                    <policyEntry topic=">" memoryLimit="5mb">
                        <subscriptionRecoveryPolicy>
                            <lastImageSubscriptionRecoveryPolicy/>
                        </subscriptionRecoveryPolicy>
                    </policyEntry>
                </policyEntries>
            </policyMap>
        </destinationPolicy>

       
        <managementContext>
            <managementContext createConnector="false"/>
        </managementContext>

       
        <networkConnectors>
           
           
            <networkConnector uri="static://(tcp://localhost:61617)"/>
        </networkConnectors>

       
       
        <persistenceAdapter>
           
      <kahaDB directory="d:/temp/activemq-data-master" enableJournalDiskSyncs="false" indexWriteBatchSize="10000" indexCacheSize="1000"/>
    </persistenceAdapter>

       
       

       
       

       
        <systemUsage>
            <systemUsage>
                <memoryUsage>
                    <memoryUsage limit="50 mb"/>
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="1 gb" name="foo"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="100 mb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>


       
        <transportConnectors>
           
            <transportConnector name="openwire" uri="tcp://localhost:61616"/>
           
        </transportConnectors>

    </broker>

Config of the Slave

    <broker xmlns="http://activemq.apache.org/schema/core" dataDirectory="d:/temp/activemq-data" brokerName="slave" useShutdownHook="false" useJmx="true" advisorySupport="false">
   
       
        <destinationPolicy>
            <policyMap>
                <policyEntries>
                    <policyEntry queue=">" memoryLimit="5mb"/>
                    <policyEntry topic=">" memoryLimit="5mb">
                        <subscriptionRecoveryPolicy>
                            <lastImageSubscriptionRecoveryPolicy/>
                        </subscriptionRecoveryPolicy>
                    </policyEntry>
                </policyEntries>
            </policyMap>
        </destinationPolicy>

       
        <managementContext>
            <managementContext createConnector="false"/>
        </managementContext>

       
        <networkConnectors>
           
           

        </networkConnectors>
               
       
               
                <persistenceAdapter>
           
     
      <kahaDB directory="d:/temp/activemq-data-slave" enableJournalDiskSyncs="false" indexWriteBatchSize="10000" indexCacheSize="1000"/>
    </persistenceAdapter>

               
       
       

       
       

       
        <systemUsage>
            <systemUsage>
                <memoryUsage>
                    <memoryUsage limit="50 mb"/>
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="1 gb" name="foo"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="100 mb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>

       

       
        <transportConnectors>
           
            <transportConnector name="openwire" uri="tcp://localhost:61617"/>
           
        </transportConnectors>
       

    </broker>

Network connection is well established

 17:52:27,090 | INFO  | xtenderThread-10 | OsgiBundleXmlApplicationContext  | ractOsgiBundleApplicationContext  348 | Not publishing application contex
t OSGi service for bundle null (activemq-broker.xml)
17:52:27,090 | INFO  | xtenderThread-10 | ContextLoaderListener            | BundleApplicationContextListener   45 | Application context successfully
refreshed (OsgiBundleXmlApplicationContext(bundle=activemq-broker.xml, config=osgibundle:/META-INF/spring/*.xml))
17:52:27,215 | INFO  | r=vm://master#12 | DemandForwardingBridge           | rk.DemandForwardingBridgeSupport  303 | Network connection between vm://m
aster#12 and tcp://localhost/127.0.0.1:61617(slave) has been established.

but when I connect with the client : ant consumer -Durl="tcp://localhost:61617" -Dqueue=IN

I don't see anything

Could it be related to this parameter  : advisorySupport="false" ?

Kind regards

Charles