activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "David Borja" <adbo...@gmail.com>
Subject Re: Network of brokers configuration ...
Date Fri, 23 Feb 2007 21:10:39 GMT
Some ideas??

Thanx!!!

On 2/23/07, David Borja <adborja@gmail.com> wrote:
>
> This is the "dllo-aborja" broker config file:
>
>
> <beans>
>
>     <!-- Allows us to use system properties as variables in this
> configuration file -->
>     <bean
>         class="
> org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" />
>
>     <broker xmlns="http://activemq.org/config/1.0 ">
>         <memoryManager>
>             <usageManager id="memory-manager" limit="50 MB" />
>         </memoryManager>
>
>         <!-- In ActiveMQ 4, you can setup destination policies -->
>         <destinationPolicy>
>             <policyMap>
>                 <policyEntries>
>
>                     <policyEntry topic="FOO.>">
>                         <dispatchPolicy>
>                             <strictOrderDispatchPolicy />
>                         </dispatchPolicy>
>                         <subscriptionRecoveryPolicy>
>                             <lastImageSubscriptionRecoveryPolicy />
>                         </subscriptionRecoveryPolicy>
>                     </policyEntry>
>
>                 </policyEntries>
>             </policyMap>
>         </destinationPolicy>
>
>
>         <persistenceAdapter>
>             <jdbcPersistenceAdapter dataDirectory="amq_data"
>                 dataSource="#mysql-ds" />
>
>         </persistenceAdapter>
>
>         <transportConnectors>
>             <!--<transportConnector name="default"
>                 uri="tcp://localhost:61616"
> discoveryUri="multicast://default" /> -->
>             <transportConnector name="openwire"
>                 uri="tcp://localhost:61616"
> discoveryUri="multicast://default" />
>             <transportConnector name="stomp"
>                 uri="stomp://localhost:61613" />
>         </transportConnectors>
>
>         <!-- <networkConnectors> -->
>         <networkConnectors>
>             <networkConnector
>
> uri="static://(tcp://dllo-aborja:61616,tcp://192.168.147.145:61616)"
>                 failover="true" name="bridge" dynamicOnly="false"
>                 conduitSubscriptions="true"
> decreaseNetworkConsumerPriority="false"
>                 networkTTL="99">
>                 <excludedDestinations>
>                     <queue physicalName=" exclude.test.foo" />
>                     <topic physicalName="exclude.test.bar " />
>                 </excludedDestinations>
>                 <dynamicallyIncludedDestinations>
>                     <queue physicalName="" />
>                 </dynamicallyIncludedDestinations>
>             </networkConnector>
>         </networkConnectors>
>     </broker>
>
>     <!-- MySql DataSource Sample Setup -->
>     <bean id="mysql-ds" class=" org.apache.commons.dbcp.BasicDataSource"
>         destroy-method="close">
>         <property name="driverClassName" value="com.mysql.jdbc.Driver " />
>         <property name="url"
>             value="jdbc:mysql://dllo-aborja/activemq?relaxAutoCommit=true"
> />
>         <property name="username" value="user" />
>         <property name="password" value="passwd" />
>         <property name="poolPreparedStatements" value="true" />
>     </bean>
>
> </beans>
>
>
> And this is the "localhost2" config file:
>
> <beans>
>   <bean class="
> org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
>
>   <broker brokerName="localhost2" useJmx="true" xmlns="
> http://activemq.org/config/1.0">
>
>     <destinationPolicy>
>       <policyMap><policyEntries>
>
>           <policyEntry topic="FOO.>">
>             <dispatchPolicy>
>               <strictOrderDispatchPolicy />
>             </dispatchPolicy>
>             <subscriptionRecoveryPolicy>
>               <lastImageSubscriptionRecoveryPolicy />
>             </subscriptionRecoveryPolicy>
>           </policyEntry>
>
>       </policyEntries></policyMap>
>     </destinationPolicy>
>
>
>     <persistenceAdapter>
>         <journaledJDBC journalLogFiles="5" dataDirectory="${activemq.base
> }/activemq-data"/>
>     </persistenceAdapter>
>
>     <transportConnectors>
>        <transportConnector name="openwire" uri="tcp://localhost:61616"
> discoveryUri="multicast://default"/>
>        <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
>     </transportConnectors>
>
>     <networkConnectors>
>       <networkConnector name="default-nc" uri="multicast://default"/>
>     </networkConnectors>
>
>   </broker>
>
> </beans>
>
> Thanx!!!
>
>
> On 2/23/07, Adrian Co <aco@exist.com > wrote:
> >
> > Could paste the config of both brokers?
> >
> > David Borja wrote:
> > > Hi ...
> > >
> > > I have a MessageListener listening on broker "localhost2" on a queue
> > > called
> > > "jms/bridge".
> > >
> > > With the configuration above, i send a message to a queue called
> > > "jms/bridge" on broker "dllo-aborja". The message listener does't
> > receive
> > > anything ... why ??
> > >
> > >
> > > Thanx!!
> > >
> > >
> > > On 2/23/07, Adrian Co < aco@exist.com> wrote:
> > >>
> > >> AFAIK, by default the network connector uses a demand forwarding
> > bridge,
> > >> and will forward messages only when there is an interested consumer
> > on
> > >> the remote broker only.
> > >>
> > >> I know there is a standard forwarding bridge, but I'm not sure how to
> > >> configure it in xbean. Sorry. :(
> > >>
> > >>
> > >> David Borja wrote:
> > >> > Hi ...
> > >> >
> > >> > This is my scenario :
> > >> >
> > >> > I hava a broker called "dllo-aborja" and other one called
> > >> "localhost2".
> > >> >
> > >> > I need that all messages that i put on some queue in dllo-aborja
> > >> broker,
> > >> > forward to localhost2 broker, including the queues ...
> > >> >
> > >> > This is my config ..
> > >> >
> > >> >
> > >> > <networkConnectors>
> > >> >    <networkConnector
> > >>
> > >> >
> > >> uri="static://(tcp://localhost:61616,tcp://192.168.147.145:61616)"
> > >> >        failover="true" name="bridge" dynamicOnly="false"
> > >> >        conduitSubscriptions="true"
> > >> > decreaseNetworkConsumerPriority="false"
> > >> >        networkTTL="99">
> > >> >        <excludedDestinations>
> > >> >            <queue physicalName="exclude.test.foo" />
> > >> >                <topic physicalName="exclude.test.bar" />
> > >> >            </excludedDestinations>
> > >> >            <dynamicallyIncludedDestinations>
> > >> >                <queue physicalName="" />
> > >> >            </dynamicallyIncludedDestinations>
> > >> >    </networkConnector>
> > >> > </networkConnectors>
> > >> >
> > >> >
> > >> > What i am missing in the configuration above ??
> > >> >
> > >> >
> > >> > Thanx!!!
> > >> >
> > >>
> > >>
> > >
> >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message