You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2010/12/22 18:10:33 UTC
svn commit: r1051992 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/BrokerDeployer.java
Author: cwiklik
Date: Wed Dec 22 17:10:33 2010
New Revision: 1051992
URL: http://svn.apache.org/viewvc?rev=1051992&view=rev
Log:
UIMA-1976 Deprecated class
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/BrokerDeployer.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/BrokerDeployer.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/BrokerDeployer.java?rev=1051992&r1=1051991&r2=1051992&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/BrokerDeployer.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/BrokerDeployer.java Wed Dec 22 17:10:33 2010
@@ -24,6 +24,7 @@ import java.net.BindException;
import java.net.ServerSocket;
import javax.management.MBeanServer;
+import javax.management.MBeanServerFactory;
import javax.management.ObjectName;
import org.apache.activemq.broker.Broker;
@@ -36,7 +37,11 @@ import org.apache.uima.util.Level;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextClosedEvent;
-
+/**
+ *
+ * @deprecated
+ *
+ */
public class BrokerDeployer implements ApplicationListener {
private static final Class CLASS_NAME = BrokerDeployer.class;
@@ -112,24 +117,9 @@ public class BrokerDeployer implements A
startPort++;
}
if (startPort < (startPort + MAX_PORT_THRESHOLD)) {
- MBeanServer jmxServer = null;
- // Check if the MBeanServer is available. If it is, plug it
- // into the
- // local Broker. We only need one MBeanServer in the JVM
- if ((jmxServer = ManagementContext.findTigerMBeanServer()) != null) {
- System.out
- .println(">>> Found TigerMBeanServer Running. Attaching Broker to Tiger.");
- service.getManagementContext()
- .setMBeanServer(jmxServer);
- // Specify JMX Port
- service.getManagementContext().setConnectorPort(
- startPort);
- } else {
- service.getManagementContext().setConnectorPort(
- startPort);
- service.setUseJmx(true);
- }
-
+ service.getManagementContext().setConnectorPort(
+ startPort);
+ service.setUseJmx(true);
System.setProperty("com.sun.management.jmxremote.port",
String.valueOf(startPort));