You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2010/09/03 12:57:03 UTC
svn commit: r992264 -
/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java
Author: robbie
Date: Fri Sep 3 10:57:02 2010
New Revision: 992264
URL: http://svn.apache.org/viewvc?rev=992264&view=rev
Log:
QPID-2843: move the 2 management port listening messages to after the respective points listening has been initiated
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java
Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java?rev=992264&r1=992263&r2=992264&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java (original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java Fri Sep 3 10:57:02 2010
@@ -190,19 +190,12 @@ public class JMXManagedObjectRegistry im
//create the SSL RMI socket factories
csf = new SslRMIClientSocketFactory();
ssf = new SslRMIServerSocketFactory();
-
- CurrentActor.get().message(ManagementConsoleMessages.LISTENING("RMI Registry", port));
- CurrentActor.get().message(ManagementConsoleMessages.LISTENING("SSL JMX RMIConnectorServer", port + PORT_EXPORT_OFFSET));
-
}
else
{
//Do not specify any specific RMI socket factories, resulting in use of the defaults.
csf = null;
ssf = null;
-
- CurrentActor.get().message(ManagementConsoleMessages.LISTENING("RMI Registry", port));
- CurrentActor.get().message(ManagementConsoleMessages.LISTENING("JMX RMIConnectorServer", port + PORT_EXPORT_OFFSET));
}
//add a JMXAuthenticator implementation the env map to authenticate the RMI based JMX connector server
@@ -224,6 +217,8 @@ public class JMXManagedObjectRegistry im
{
_rmiRegistry = LocateRegistry.createRegistry(port, null, null);
}
+
+ CurrentActor.get().message(ManagementConsoleMessages.LISTENING("RMI Registry", port));
/*
* We must now create the RMI ConnectorServer manually, as the JMX Factory methods use RMI calls
@@ -316,6 +311,8 @@ public class JMXManagedObjectRegistry im
_cs.start();
+ String connectorServer = (sslEnabled ? "SSL " : "") + "JMX RMIConnectorServer";
+ CurrentActor.get().message(ManagementConsoleMessages.LISTENING(connectorServer, port + PORT_EXPORT_OFFSET));
CurrentActor.get().message(ManagementConsoleMessages.READY());
}
@@ -398,7 +395,7 @@ public class JMXManagedObjectRegistry im
// Stopping the JMX ConnectorServer
try
{
- CurrentActor.get().message(ManagementConsoleMessages.SHUTTING_DOWN("RMI ConnectorServer", _cs.getAddress().getPort()));
+ CurrentActor.get().message(ManagementConsoleMessages.SHUTTING_DOWN("JMX RMIConnectorServer", _cs.getAddress().getPort()));
_cs.stop();
}
catch (IOException e)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org