1 25 package classic; 26 27 import org.objectweb.joram.client.jms.admin.*; 28 import org.objectweb.joram.client.jms.*; 29 import org.objectweb.joram.client.jms.tcp.*; 30 31 32 35 public class SSLClassicAdmin 36 { 37 public static void main(String [] args) throws Exception 38 { 39 System.out.println(); 40 System.out.println("SSL Classic administration..."); 41 42 AdminModule.connect("root", "root", 60, "org.objectweb.joram.client.jms.tcp.ReliableSSLTcpClient"); 43 44 Queue queue = (Queue) Queue.create("queue"); 45 Topic topic = (Topic) Topic.create("topic"); 46 47 User user = User.create("anonymous", "anonymous"); 48 49 queue.setFreeReading(); 50 topic.setFreeReading(); 51 queue.setFreeWriting(); 52 topic.setFreeWriting(); 53 54 javax.jms.ConnectionFactory cf = 55 TcpConnectionFactory.create("localhost", 56 16010, 57 "org.objectweb.joram.client.jms.tcp.ReliableSSLTcpClient"); 58 javax.jms.QueueConnectionFactory qcf = 59 QueueTcpConnectionFactory.create("localhost", 60 16010, 61 "org.objectweb.joram.client.jms.tcp.ReliableSSLTcpClient"); 62 javax.jms.TopicConnectionFactory tcf = 63 TopicTcpConnectionFactory.create("localhost", 64 16010, 65 "org.objectweb.joram.client.jms.tcp.ReliableSSLTcpClient"); 66 67 javax.naming.Context jndiCtx = new javax.naming.InitialContext (); 68 jndiCtx.bind("cf", cf); 69 jndiCtx.bind("qcf", qcf); 70 jndiCtx.bind("tcf", tcf); 71 jndiCtx.bind("queue", queue); 72 jndiCtx.bind("topic", topic); 73 jndiCtx.close(); 74 75 AdminModule.disconnect(); 76 System.out.println("SSL Admin closed."); 77 } 78 } 79 | Popular Tags |