1 23 package bridge; 24 25 import org.objectweb.joram.client.jms.admin.*; 26 import org.objectweb.joram.client.jms.*; 27 import org.objectweb.joram.client.jms.tcp.*; 28 29 import java.util.Properties ; 30 31 32 35 public class BridgeAdmin { 36 public static void main(String [] args) throws Exception { 37 System.out.println(); 38 System.out.println("Bridge administration..."); 39 40 AdminModule.connect("root", "root", 60); 41 javax.naming.Context jndiCtx = new javax.naming.InitialContext (); 42 43 Queue foreignQueue = Queue.create(1, "foreignQueue"); 45 foreignQueue.setFreeReading(); 46 foreignQueue.setFreeWriting(); 47 System.out.println("foreign queue = " + foreignQueue); 48 49 Topic foreignTopic = Topic.create(1, "foreignTopic"); 50 foreignTopic.setFreeReading(); 51 foreignTopic.setFreeWriting(); 52 System.out.println("foreign topic = " + foreignTopic); 53 54 javax.jms.ConnectionFactory foreignCF = TcpConnectionFactory.create("localhost", 16011); 55 56 jndiCtx.rebind("foreignQueue", foreignQueue); 58 jndiCtx.rebind("foreignTopic", foreignTopic); 59 jndiCtx.rebind("foreignCF", foreignCF); 60 61 62 Properties prop = new Properties (); 64 prop.setProperty("connectionFactoryName", "foreignCF"); 66 prop.setProperty("destinationName", "foreignQueue"); 68 prop.setProperty("automaticRequest", "false"); 70 71 Queue joramQueue = Queue.create(0, 73 "org.objectweb.joram.mom.dest.bridge.BridgeQueue", 74 prop); 75 joramQueue.setFreeReading(); 76 joramQueue.setFreeWriting(); 77 System.out.println("joram queue = " + joramQueue); 78 79 prop = new Properties (); 81 prop.setProperty("connectionFactoryName", "foreignCF"); 83 prop.setProperty("destinationName", "foreignTopic"); 85 86 Topic joramTopic = Topic.create(0, 88 "org.objectweb.joram.mom.dest.bridge.BridgeTopic", 89 prop); 90 joramTopic.setFreeReading(); 91 joramTopic.setFreeWriting(); 92 System.out.println("joram topic = " + joramTopic); 93 94 javax.jms.ConnectionFactory joramCF = TcpConnectionFactory.create(); 95 96 User.create("anonymous", "anonymous", 0); 97 User.create("anonymous", "anonymous", 1); 98 99 jndiCtx.rebind("joramQueue", joramQueue); 100 jndiCtx.rebind("joramTopic", joramTopic); 101 jndiCtx.rebind("joramCF", joramCF); 102 103 jndiCtx.close(); 104 105 AdminModule.disconnect(); 106 System.out.println("Admin closed."); 107 } 108 } 109 | Popular Tags |