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.
