@InterfaceAudience.Private public class JMXListener extends Object implements MasterCoprocessor, RegionServerCoprocessor
Coprocessor.State
Modifier and Type | Field and Description |
---|---|
static int |
defMasterRMIRegistryPort |
static int |
defRegionserverRMIRegistryPort |
private static JMXConnectorServer |
JMX_CS
workaround for HBASE-11146 master and regionserver are in 1 JVM in standalone mode only 1 JMX
instance is allowed, otherwise there is port conflict even if we only load regionserver
coprocessor on master
|
private static org.slf4j.Logger |
LOG |
static String |
RMI_CONNECTOR_PORT_CONF_KEY |
static String |
RMI_REGISTRY_PORT_CONF_KEY |
private Registry |
rmiRegistry |
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Constructor and Description |
---|
JMXListener() |
Modifier and Type | Method and Description |
---|---|
static JMXServiceURL |
buildJMXServiceURL(int rmiRegistryPort,
int rmiConnectorPort) |
void |
start(CoprocessorEnvironment env)
Called by the
CoprocessorEnvironment during it's own startup to initialize the
coprocessor. |
void |
startConnectorServer(int rmiRegistryPort,
int rmiConnectorPort) |
void |
stop(CoprocessorEnvironment env)
Called by the
CoprocessorEnvironment during it's own shutdown to stop the coprocessor. |
void |
stopConnectorServer() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getMasterObserver
getRegionServerObserver
getServices
private static final org.slf4j.Logger LOG
public static final String RMI_REGISTRY_PORT_CONF_KEY
public static final String RMI_CONNECTOR_PORT_CONF_KEY
public static final int defMasterRMIRegistryPort
public static final int defRegionserverRMIRegistryPort
private static JMXConnectorServer JMX_CS
private Registry rmiRegistry
public JMXListener()
public static JMXServiceURL buildJMXServiceURL(int rmiRegistryPort, int rmiConnectorPort) throws IOException
IOException
public void startConnectorServer(int rmiRegistryPort, int rmiConnectorPort) throws IOException
IOException
public void stopConnectorServer() throws IOException
IOException
public void start(CoprocessorEnvironment env) throws IOException
Coprocessor
CoprocessorEnvironment
during it's own startup to initialize the
coprocessor.start
in interface Coprocessor
IOException
public void stop(CoprocessorEnvironment env) throws IOException
Coprocessor
CoprocessorEnvironment
during it's own shutdown to stop the coprocessor.stop
in interface Coprocessor
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.