activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wconroy <wcon...@gmail.com>
Subject Re: Discovery Fail if no Broker
Date Wed, 21 Jun 2006 21:24:40 GMT

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.


Mime
View raw message