Re: Discovery Fail if no Broker

[lchui <lc...@adomo.com>]

I am currently using ActiveMQ version 4.1.1 and run into the exact same
problem. Wondering if this bug not fixed or my configuration is wrong?

Thanks,
Lisa


Hiram Chirino wrote:
> 
> Then this looks like a bug on ActiveMQ.. Could you past that info into
> a new JIRA issue at:
> 
> http://issues.apache.org/activemq/browse/AMQ
> 
> Regards,
> Hiram
> 
> On 6/21/06, wconroy <wc...@gmail.com> wrote:
>>
>> Thanks for the quick reply.
>>
>> I am trying to connect with the following now.
>>
>> discovery:(multicast://default)?maxReconnectAttempts=1
>>
>> and this is the output.
>>
>> 0 [main] INFO test.activemq.MyActiveMQSubscriber  - Connecting to:
>> discovery:(multicast://default)?maxReconnectAttempts=1
>> 959 [main] WARN
>> org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent 
>> -
>> brokerName not set
>> 969 [main] DEBUG org.apache.activemq.transport.failover.FailoverTransport 
>> -
>> Started.
>> 984 [main] DEBUG org.apache.activemq.transport.failover.FailoverTransport 
>> -
>> Waiting for transport to reconnect.
>> 1987 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>> 2988 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>> 3990 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>> 4992 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>> 5994 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>> 6996 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>> 7997 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>> 8999 [main] DEBUG
>> org.apache.activemq.transport.failover.FailoverTransport
>> - Waiting for transport to reconnect.
>>
>> It goes on indefinitely, so I would assume that it is not working
>> properly.
>> I am using 4.0 and am purposely not starting a broker.
>>
>> Here is the source I am running.
>>
>> public class MyActiveMQSubscriber {
>>
>>     public static void main(String[] args) throws Exception {
>>         BasicConfigurator.configure();
>>
>>         String url =
>> "discovery:(multicast://default)?maxReconnectAttempts=1";
>>         Logger.getLogger(MyActiveMQSubscriber.class).info("Connecting to:
>> "
>> + url);
>>         Connection connection = createConnection(url);
>>
>>         Session session = createSession(connection);
>>         MessageConsumer consumer = creatConsumer(session);
>>         System.out.println("Connection created");
>>
>>         Message m;
>>         while ((m = consumer.receive()) != null) {
>>             Logger.getLogger(MyActiveMQSubscriber.class).info("Got
>> message:
>> " + m);
>>         }
>>     }
>>
>>     public static Connection createConnection(String url) throws
>> Exception {
>>         ActiveMQConnectionFactory connectionFactory = new
>> ActiveMQConnectionFactory(url);
>>         Connection connection = connectionFactory.createConnection();
>>         connection.start();
>>         return connection;
>>
>>     }
>>
>>     public static Session createSession(Connection connection) throws
>> Exception {
>>         Session session = connection.createSession(false,
>> Session.AUTO_ACKNOWLEDGE);
>>         return session;
>>     }
>>
>>     public static MessageConsumer creatConsumer(Session session) throws
>> Exception {
>>         MessageConsumer consumer =
>> session.createConsumer(session.createTopic("SecurityChanged"));
>>         return consumer;
>>     }
>>
>>     protected static void close(Connection connection, Session session)
>> throws JMSException {
>>         // lets dump the stats
>>         dumpStats(connection);
>>
>>         if (session != null) {
>>             session.close();
>>         }
>>         if (connection != null) {
>>             connection.close();
>>         }
>>     }
>>
>>     protected static void dumpStats(Connection connection) {
>>         ActiveMQConnection c = (ActiveMQConnection) connection;
>>         c.getConnectionStats().dump(new IndentPrinter());
>>     }
>>
>> }
>>
>>
>> Thank you very much for your help.
>>
>> --Bo
>> --
>> View this message in context:
>> http://www.nabble.com/Discovery-Fail-if-no-Broker-t1824894.html#a4982927
>> Sent from the ActiveMQ - User forum at Nabble.com.
>>
>>
> 
> 
> -- 
> Regards,
> Hiram
> 
> Blog: http://hiramchirino.com
> 
> 

-- 
View this message in context: http://www.nabble.com/Discovery-Fail-if-no-Broker-tf1824894s2354.html#a10692075
Sent from the ActiveMQ - User mailing list archive at Nabble.com.