Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-users@geronimo.apache.org
Received-SPF: pass (asf.osuosl.org: domain of james.strachan@gmail.com
 designates 66.249.92.172 as permitted sender)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
        s=beta; d=gmail.com;
        h=received:message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references;
        b=UAGz10y1kd7o6NL4HYStouviXjD+mTAorbbKpyqvyEPoffVJ59zGaK3BYteV2sCMhjtRQpQ36T/B9PbrAT8xkbmcP+XucKFMd95Kqdv3BMNLYPgLOTOoBVniYpGeJPc34ZPuh6PcYQ5QRzVJLHXWOaZQcDklN6mjJCJYoqEEFz0=
Message-ID: <ec6e67fd0607280512w7ea63673g423289a840fb6727@mail.gmail.com>
Date: Fri, 28 Jul 2006 13:12:15 +0100
From: "James Strachan" <james.strachan@gmail.com>
To: activemq-users@geronimo.apache.org
Subject: Re: broker static dynamic IP list
In-Reply-To: <5538264.post@talk.nabble.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit
Content-Disposition: inline
References: <5519815.post@talk.nabble.com>
	 <af2843cd0607271028t24fce01cr9fe5fa512fd1337e@mail.gmail.com>
	 <5536541.post@talk.nabble.com>
	 <ec6e67fd0607280251m4cee1bc6r2087e8df542c03f1@mail.gmail.com>
	 <5537215.post@talk.nabble.com>
	 <ec6e67fd0607280437h7d22c4fsa9dc4da2e0b27856@mail.gmail.com>
	 <5538074.post@talk.nabble.com>
	 <ec6e67fd0607280455x36973f38u7f8d2e09449a729f@mail.gmail.com>
	 <5538264.post@talk.nabble.com>

Does the JVM start up any other JMS connections using "vm://" before
you start the broker?

On 7/28/06, Venkatg <venkatabbu@yahoo.com> wrote:
>
>
> 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.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/