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