1 18 package org.apache.activemq.transport.xmpp; 19 20 import org.apache.activemq.Service; 21 import org.apache.activemq.broker.BrokerService; 22 23 26 public class XmppBroker implements Service { 27 private BrokerService broker = new BrokerService(); 28 29 public static void main(String [] args) { 30 try { 31 XmppBroker broker = new XmppBroker(); 32 broker.start(); 33 34 System.out.println("Press any key to terminate"); 35 System.in.read(); 36 } 37 catch (Exception e) { 38 System.out.println("Caught: " + e); 39 e.printStackTrace(); 40 } 41 } 42 43 public void start() throws Exception { 44 broker.setPersistent(false); 45 broker.setUseJmx(false); 46 broker.addConnector("xmpp://localhost:61222"); 47 broker.start(); 48 } 49 50 public void stop() throws Exception { 51 broker.stop(); 52 } 53 } 54 | Popular Tags |