package activemqjndi; import javax.jms.*; import org.apache.activemq.*; import javax.naming.InitialContext; import java.util.Properties; import org.apache.activemq.command.*; public class Main { /** Creates a new instance of Main */ public Main() { } /** * @param args the command line arguments */ public static void main(String[] args) { try { Properties props = new Properties(); props.put("java.naming.factory.initial", "com.sun.jndi.fscontext.RefFSContextFactory"); props.put("java.naming.provider.url", "file:/space/activemqobjects"); InitialContext jndiContext = new InitialContext(props); ActiveMQQueue mq = new ActiveMQQueue("Send"); ActiveMQQueue outmq = new ActiveMQQueue("Receive"); ActiveMQTopic top = new ActiveMQTopic("ReceiveTopic"); ActiveMQXAConnectionFactory confac = new ActiveMQXAConnectionFactory(); ActiveMQConnectionFactory confac1 = new ActiveMQConnectionFactory(); jndiContext.rebind("Send", mq); jndiContext.rebind("Receive", outmq); jndiContext.rebind("ReceiveTopic", top); jndiContext.rebind("activemqconnectionfactory", confac); jndiContext.rebind("activemqnonxaconnectionfactory", confac1); } catch (Exception e) { System.out.println("Could not create JNDI " + "context: " + e.toString()); System.exit(1); } } }