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 <[EMAIL PROTECTED]> 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 <[EMAIL PROTECTED]> 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!!!
>> >
>>
>>
>
