activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Venkatg <venkata...@yahoo.com>
Subject Re: broker static dynamic IP list
Date Fri, 28 Jul 2006 11:59:54 GMT


public class BrokerMain 
{ 
    public static void main(String[] args) 
    { 
        final BrokerService broker = new BrokerService();; 
        Runnable doRun = new Runnable(){ 
            public void run() 
             { 
                try 
                { 
                
                    broker.setBrokerName("FE-Test"); 
                    broker.addConnector(new URI("tcp://localhost:61616")); 
                    thrdBroker.setBrokerName("BEServer");                     
                    thrdBroker.setPersistent(false); 
                    thrdBroker.setUseJmx(false); 
                    thrdBroker.start(); 
                } catch (Exception e) 
                { 
                    e.printStackTrace(); 
                } 
            } 
        }; 
        Thread thrd = new Thread(doRun); 
        thrd.start(); 
        ProducerTool publisher = new ProducerTool(); 
        while( !broker.isStarted() ); 

        BufferedReader waiter = new BufferedReader(new
InputStreamReader(System.in)); 
        String input = null; 
        try 
        { 
            System.out.println("Following Commands are supported"); 
            System.out.println("Publish Messages => 1"); 
            System.out.println("Add N/W Connector => 2"); 
            System.out.println("Stop Broker => 3"); 
            int opCode = -1; 
            boolean isStopped = false; 
            while( !isStopped && ( input = waiter.readLine()) != null ) 
            { 
                opCode = Integer.parseInt(input); 
                switch( opCode ) 
                { 
                    case 1: 
                        { 
                            ProducerTool.runTool( args, publisher); 
                        } 
                        break; 
                    case 2: 
                        { 
                            System.out.println("Enter Broker IPAddress and
Port (Ex:10.10.8.212:6333) :"); 
                            String ipAddress = waiter.readLine(); 
                            if( ipAddress != null && ipAddress.length() > 0
) 
                            { 
                               
broker.addNetworkConnector("static:(tcp://"+ipAddress+")");                              

                            } 
                        } 
                        break; 
                    case 3: 
                        { 
                            isStopped = true; 
                        } 
                        break; 
                    default: 
                } 

            } 
        } catch (IOException e) 
        { 
            e.printStackTrace(); 
        } catch (Exception e) 
        { 
            e.printStackTrace(); 
        } finally 
        { 
            try 
            { 
                broker.stop(); 
            } catch (Exception e) 
            { 
                e.printStackTrace(); 
            } 
        } 
    } 

Thanks
 Venkat
-- 
View this message in context: http://www.nabble.com/broker-static-dynamic-IP-list-tf2009183.html#a5538264
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message