I've opened the following JIRA against the documentation.
https://issues.apache.org/activemq/browse/AMQ-1590
Joe
www.ttmsolutions.com
rajdavies wrote:
>
> We do rely on advisories being present for networks to function
> correctly at present I'm afraid
>
> cheers,
>
> Rob
> On 19 Feb 2008, at 17:38, wha wrote:
>
>>
>> Well I don't know what to say, it doesn't work for me when I do
>> advisorySupport="false"
>>
>> If you want to try it. Here's my BrokerA activemq.xml
>>
>> <broker xmlns="http://activemq.org/config/1.0"
>> brokerName="brokerA"
>> dataDirectory="${activemq.base}/data"
>> useJmx="true"
>> advisorySupport="false">
>>
>> <transportConnectors>
>> <transportConnector name="inFromProducer" uri="tcp://localhost:
>> 8881"
>> />
>> </transportConnectors>
>>
>> <networkConnectors>
>> <networkConnector name="outToBrokerB"
>> uri="static://(tcp://localhost:9991)" dynamicOnly="true"
>> networkTTL="3">
>> </networkConnector>
>> </networkConnectors>
>> </broker>
>>
>> Here's my BrokerB, activemq.xml
>>
>> <broker xmlns="http://activemq.org/config/1.0"
>> brokerName="brokerB"
>> dataDirectory="${activemq.base}/data"
>> useJmx="true"
>> advisorySupport="true">
>>
>> <transportConnectors>
>> <transportConnector name="inFromBrokerA" uri="tcp://localhost:
>> 9991"
>> />
>> </transportConnectors>
>>
>> <networkConnectors>
>> </networkConnectors>
>> </broker>
>>
>>
>> Here's my consumer code:
>>
>> public void run()
>> {
>> //Create a connection
>> Connection conn = null;
>> String user = null;
>> String passw = null;
>> String brokerurl = "tcp://localhost:9991";
>> try
>> {
>> ActiveMQConnectionFactory connFactory = new
>> ActiveMQConnectionFactory(user,passw,brokerurl);
>> conn = connFactory.createConnection();
>> conn.start();
>>
>> session = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
>> conn.setExceptionListener(this);
>>
>> Queue dest = session.createQueue("TEST.Q1");
>>
>> MessageConsumer msgConsumer = session.createConsumer(dest);
>>
>> msgConsumer.setMessageListener(this);
>>
>> System.out.println("Listening Q1...");
>>
>> }
>> catch (JMSException jmse)
>> {
>> System.out.println("JMSException in run() : " + jmse);
>> }
>> }
>>
>> public void onException(JMSException jmse)
>> {
>> System.out.println(jmse);
>> }
>>
>> public void onMessage(Message mess)
>> {
>> try
>> {
>> //Thread.sleep(5 * 1000);
>>
>> DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd
>> HH:mm:ss");
>> java.util.Date date = new java.util.Date();
>>
>> System.out.println(dateFormat.format(date) + " - Received msg: " +
>> ((TextMessage)mess).getText());
>> mess.acknowledge();
>>
>> }
>> catch (JMSException jmse)
>> {
>> System.out.println("JMSException in onMessage()" + jmse);
>> }
>> }
>>
>> And I didn't use any custom producer. I used the "Send To" from the
>> Web
>> Admin Queues page.
>>
>> When I turn the advisorySupport to "false" on BrokerB, Store and
>> Forward
>> stops working.
>>
>> Is this a bug ? Should I post a Jira ?
>>
>> Thanks
>> -Willy.
>>
>>
>>
>> ttmdev wrote:
>>>
>>> The default setting for advisorySupport is 'true' and I don't think
>>> that
>>> the forwarding of messages has any dependencies on advisorySupport.
>>>
>>> Joe
>>> www.ttmsolutions.com
>>>
>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Network-of-Brokers---Broker-A-talking-to-Broker-B-tp15510192s2354p15562341.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>
>
>
--
View this message in context: http://www.nabble.com/Network-of-Brokers---Broker-A-talking-to-Broker-B-tp15510192s2354p15594116.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
|