activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hiram Chirino" <hi...@hiramchirino.com>
Subject Re: Discovery Fail if no Broker
Date Wed, 21 Jun 2006 22:33:03 GMT
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 <wconroy@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

Mime
View raw message