AmqJonRuntimeTestBase.java 文件源码

@Before
public void setUp() throws Exception {
   super.setUp();
   leakCheckRule.disable();

   jmxServiceURL = "service:jmx:rmi://localhost/jndi/rmi://localhost:" + jmxPort + "/jmxrmi";
   server = createServer(true, true);
   Configuration serverConfig = server.getConfiguration();
   serverConfig.setJMXManagementEnabled(true);
   serverConfig.setName(brokerName);
   String dataDir = this.temporaryFolder.getRoot().getAbsolutePath();
   serverConfig.setPagingDirectory(dataDir + "/" + serverConfig.getPagingDirectory());
   serverConfig.setBindingsDirectory(dataDir + "/" + serverConfig.getBindingsDirectory());
   serverConfig.setLargeMessagesDirectory(dataDir + "/" + serverConfig.getLargeMessagesDirectory());
   serverConfig.setJournalDirectory(dataDir + "/" + serverConfig.getJournalDirectory());

   mbeanServer = MBeanServerFactory.createMBeanServer();
   server.setMBeanServer(mbeanServer);
   server.start();
   factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
   objectNameBuilder = server.getManagementService().getObjectNameBuilder();
   connectJmx();
   System.out.println("server name: " + server.getConfiguration().getName());

   emsFactory = new ConnectionFactory();
   ConnectionSettings emsConnectionSettings = new ConnectionSettings();
   JSR160ConnectionTypeDescriptor descriptor = new JSR160ConnectionTypeDescriptor();
   emsConnectionSettings.initializeConnectionType(descriptor);
   emsConnectionSettings.setServerUrl(jmxServiceURL);

   ConnectionProvider provider = emsFactory.getConnectionProvider(emsConnectionSettings);
   emsConnection = provider.connect();
   emsConnection.loadSynchronous(true);
}