Package org.apache.flink.management.jmx
Class JMXService
- java.lang.Object
-
- org.apache.flink.management.jmx.JMXService
-
public class JMXService extends Object
Provide a JVM-wide singleton JMX Service.
-
-
Constructor Summary
Constructors Constructor Description JMXService()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Optional<org.apache.flink.management.jmx.JMXServer>getInstance()Acquire the global singleton JMXServer instance.static Optional<Integer>getPort()static voidstartInstance(String portsConfig)Start the JMV-wide singleton JMX server.static voidstopInstance()Stop the JMX server.
-
-
-
Method Detail
-
getInstance
public static Optional<org.apache.flink.management.jmx.JMXServer> getInstance()
Acquire the global singleton JMXServer instance.
-
startInstance
public static void startInstance(String portsConfig)
Start the JMV-wide singleton JMX server.If JMXServer static instance is already started, it will not be started again. Instead a warning will be logged indicating which port the existing JMXServer static instance is exposing.
- Parameters:
portsConfig- port configuration of the JMX server.
-
stopInstance
public static void stopInstance() throws IOExceptionStop the JMX server.- Throws:
IOException
-
-