activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ttmdev <joe.fernan...@ttmsolutions.com>
Subject Re: Network of Brokers - Broker A talking to Broker B
Date Wed, 20 Feb 2008 17:30:15 GMT

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.


Mime
View raw message