http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c9b1dfb3/modules/core/src/main/java/org/apache/ignite/streamer/StreamerMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerMBean.java b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerMBean.java index cdc944d..18eaf35 100644 --- a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerMBean.java @@ -23,14 +23,14 @@ import org.jetbrains.annotations.*; /** * Streamer MBean interface. */ -@IgniteMXBeanDescription("MBean that provides access to streamer description and metrics.") +@MXBeanDescription("MBean that provides access to streamer description and metrics.") public interface StreamerMBean { /** * Gets streamer name. * * @return Streamer name. */ - @IgniteMXBeanDescription("Streamer name.") + @MXBeanDescription("Streamer name.") @Nullable public String getName(); /** @@ -38,7 +38,7 @@ public interface StreamerMBean { * * @return {@code True} if {@code atLeastOnce} is configured. */ - @IgniteMXBeanDescription("True if atLeastOnce is configured.") + @MXBeanDescription("True if atLeastOnce is configured.") public boolean isAtLeastOnce(); /** @@ -47,7 +47,7 @@ public interface StreamerMBean { * * @return Stage future map size. */ - @IgniteMXBeanDescription("Stage future map size.") + @MXBeanDescription("Stage future map size.") public int getStageFutureMapSize(); /** @@ -55,7 +55,7 @@ public interface StreamerMBean { * * @return Batch future map size. */ - @IgniteMXBeanDescription("Batch future map size.") + @MXBeanDescription("Batch future map size.") public int getBatchFutureMapSize(); /** @@ -63,7 +63,7 @@ public interface StreamerMBean { * * @return Number of stages. Cannot be more than pool thread count. */ - @IgniteMXBeanDescription("Number of stages currently being executed in streamer pool.") + @MXBeanDescription("Number of stages currently being executed in streamer pool.") public int getStageActiveExecutionCount(); /** @@ -71,7 +71,7 @@ public interface StreamerMBean { * * @return Number of event batches waiting to be processed. */ - @IgniteMXBeanDescription("Number of event batches currently waiting to be executed.") + @MXBeanDescription("Number of event batches currently waiting to be executed.") public int getStageWaitingExecutionCount(); /** @@ -79,7 +79,7 @@ public interface StreamerMBean { * * @return Total number of stages executed since last reset. */ - @IgniteMXBeanDescription("Total number of stages executed since last reset.") + @MXBeanDescription("Total number of stages executed since last reset.") public long getStageTotalExecutionCount(); /** @@ -89,7 +89,7 @@ public interface StreamerMBean { * * @return Pipeline maximum execution time. */ - @IgniteMXBeanDescription("Pipeline maximum execution time.") + @MXBeanDescription("Pipeline maximum execution time.") public long getPipelineMaximumExecutionTime(); /** @@ -99,7 +99,7 @@ public interface StreamerMBean { * * @return Pipeline minimum execution time. */ - @IgniteMXBeanDescription("Pipeline minimum execution time.") + @MXBeanDescription("Pipeline minimum execution time.") public long getPipelineMinimumExecutionTime(); /** @@ -108,7 +108,7 @@ public interface StreamerMBean { * * @return Pipeline average execution time. */ - @IgniteMXBeanDescription("Pipeline average execution time.") + @MXBeanDescription("Pipeline average execution time.") public long getPipelineAverageExecutionTime(); /** @@ -117,7 +117,7 @@ public interface StreamerMBean { * * @return Maximum number of unique nodes in pipeline execution. */ - @IgniteMXBeanDescription("Maximum number of unique nodes participated in pipeline execution.") + @MXBeanDescription("Maximum number of unique nodes participated in pipeline execution.") public int getPipelineMaximumExecutionNodes(); /** @@ -126,7 +126,7 @@ public interface StreamerMBean { * * @return Minimum number of unique nodes in pipeline execution. */ - @IgniteMXBeanDescription("Minimum number of unique nodes participated in pipeline execution.") + @MXBeanDescription("Minimum number of unique nodes participated in pipeline execution.") public int getPipelineMinimumExecutionNodes(); /** @@ -135,7 +135,7 @@ public interface StreamerMBean { * * @return Average number of unique nodes in pipeline execution. */ - @IgniteMXBeanDescription("Average number of unique nodes participated in pipeline execution.") + @MXBeanDescription("Average number of unique nodes participated in pipeline execution.") public int getPipelineAverageExecutionNodes(); /** @@ -145,7 +145,7 @@ public interface StreamerMBean { * * @return Number of current active sessions. */ - @IgniteMXBeanDescription("Number of current active sessions.") + @MXBeanDescription("Number of current active sessions.") public int getCurrentActiveSessions(); /** @@ -155,7 +155,7 @@ public interface StreamerMBean { * * @return Maximum active sessions since last reset. */ - @IgniteMXBeanDescription("Maximum number of active sessions since last reset.") + @MXBeanDescription("Maximum number of active sessions since last reset.") public int getMaximumActiveSessions(); /** @@ -164,6 +164,6 @@ public interface StreamerMBean { * * @return Failures count. */ - @IgniteMXBeanDescription("Number of failures since last reset.") + @MXBeanDescription("Number of failures since last reset.") public int getFailuresCount(); }
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c9b1dfb3/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStageMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStageMBean.java b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStageMBean.java index 5651f7c..8e46c77 100644 --- a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStageMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerStageMBean.java @@ -22,14 +22,14 @@ import org.apache.ignite.mxbean.*; /** * Streamer stage MBean. */ -@IgniteMXBeanDescription("MBean that provides access to streamer stage description and metrics.") +@MXBeanDescription("MBean that provides access to streamer stage description and metrics.") public interface StreamerStageMBean { /** * Gets stage name. * * @return Stage name. */ - @IgniteMXBeanDescription("Stage name.") + @MXBeanDescription("Stage name.") public String getName(); /** @@ -37,7 +37,7 @@ public interface StreamerStageMBean { * * @return Stage class name. */ - @IgniteMXBeanDescription("Stage class name.") + @MXBeanDescription("Stage class name.") public String getStageClassName(); /** @@ -45,7 +45,7 @@ public interface StreamerStageMBean { * * @return Stage minimum execution time. */ - @IgniteMXBeanDescription("Stage minimum execution time.") + @MXBeanDescription("Stage minimum execution time.") public long getMinimumExecutionTime(); /** @@ -53,7 +53,7 @@ public interface StreamerStageMBean { * * @return Stage maximum execution time. */ - @IgniteMXBeanDescription("Stage maximum execution time.") + @MXBeanDescription("Stage maximum execution time.") public long getMaximumExecutionTime(); /** @@ -61,7 +61,7 @@ public interface StreamerStageMBean { * * @return Stage average execution time. */ - @IgniteMXBeanDescription("Stage average execution time.") + @MXBeanDescription("Stage average execution time.") public long getAverageExecutionTime(); /** @@ -69,7 +69,7 @@ public interface StreamerStageMBean { * * @return Stage minimum waiting time. */ - @IgniteMXBeanDescription("Stage minimum waiting time.") + @MXBeanDescription("Stage minimum waiting time.") public long getMinimumWaitingTime(); /** @@ -77,7 +77,7 @@ public interface StreamerStageMBean { * * @return Stage maximum waiting time. */ - @IgniteMXBeanDescription("Stage maximum waiting time.") + @MXBeanDescription("Stage maximum waiting time.") public long getMaximumWaitingTime(); /** @@ -85,7 +85,7 @@ public interface StreamerStageMBean { * * @return Stage average waiting time. */ - @IgniteMXBeanDescription("Stage average waiting time.") + @MXBeanDescription("Stage average waiting time.") public long getAverageWaitingTime(); /** @@ -93,7 +93,7 @@ public interface StreamerStageMBean { * * @return Number of times this stage was executed. */ - @IgniteMXBeanDescription("Number of times this stage was executed.") + @MXBeanDescription("Number of times this stage was executed.") public long getTotalExecutionCount(); /** @@ -101,7 +101,7 @@ public interface StreamerStageMBean { * * @return Stage failure count. */ - @IgniteMXBeanDescription("Stage failure count.") + @MXBeanDescription("Stage failure count.") public int getFailuresCount(); /** @@ -109,6 +109,6 @@ public interface StreamerStageMBean { * * @return {@code True} if stage is executing now. */ - @IgniteMXBeanDescription("Whether stage is currently being executed.") + @MXBeanDescription("Whether stage is currently being executed.") public boolean isExecuting(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c9b1dfb3/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindowMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindowMBean.java b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindowMBean.java index 4a78d1d..f0f240d 100644 --- a/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindowMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/streamer/StreamerWindowMBean.java @@ -22,14 +22,14 @@ import org.apache.ignite.mxbean.*; /** * Streamer window MBean. */ -@IgniteMXBeanDescription("MBean that provides access to streamer window description.") +@MXBeanDescription("MBean that provides access to streamer window description.") public interface StreamerWindowMBean { /** * Gets window name. * * @return Window name. */ - @IgniteMXBeanDescription("Window name.") + @MXBeanDescription("Window name.") public String getName(); /** @@ -37,7 +37,7 @@ public interface StreamerWindowMBean { * * @return Window class name. */ - @IgniteMXBeanDescription("Window class name.") + @MXBeanDescription("Window class name.") public String getClassName(); /** @@ -45,7 +45,7 @@ public interface StreamerWindowMBean { * * @return Current window size. */ - @IgniteMXBeanDescription("Window size.") + @MXBeanDescription("Window size.") public int getSize(); /** @@ -53,6 +53,6 @@ public interface StreamerWindowMBean { * * @return Eviction queue size estimate. */ - @IgniteMXBeanDescription("Eviction queue size estimate.") + @MXBeanDescription("Eviction queue size estimate.") public int getEvictionQueueSize(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c9b1dfb3/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderMBean.java b/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderMBean.java index c162215..a256985 100644 --- a/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/streamer/index/StreamerIndexProviderMBean.java @@ -29,7 +29,7 @@ public interface StreamerIndexProviderMBean { * * @return Index name. */ - @IgniteMXBeanDescription("Index name.") + @MXBeanDescription("Index name.") @Nullable public String name(); /** @@ -37,7 +37,7 @@ public interface StreamerIndexProviderMBean { * * @return Index updater class. */ - @IgniteMXBeanDescription("Index updater class name.") + @MXBeanDescription("Index updater class name.") public String updaterClass(); /** @@ -45,7 +45,7 @@ public interface StreamerIndexProviderMBean { * * @return Index unique flag. */ - @IgniteMXBeanDescription("Index unique flag.") + @MXBeanDescription("Index unique flag.") public boolean unique(); /** @@ -53,7 +53,7 @@ public interface StreamerIndexProviderMBean { * * @return Index sorted flag. */ - @IgniteMXBeanDescription("Index sorted flag.") + @MXBeanDescription("Index sorted flag.") public boolean sorted(); /** @@ -61,7 +61,7 @@ public interface StreamerIndexProviderMBean { * * @return Index policy. */ - @IgniteMXBeanDescription("Index policy.") + @MXBeanDescription("Index policy.") public StreamerIndexPolicy policy(); /** @@ -69,6 +69,6 @@ public interface StreamerIndexProviderMBean { * * @return Current index size. */ - @IgniteMXBeanDescription("Current index size.") + @MXBeanDescription("Current index size.") public int size(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c9b1dfb3/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java b/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java index a77e35f..73789c4 100644 --- a/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java @@ -153,7 +153,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * * @return Some string. */ - @IgniteMXBeanDescription("MBeanROGetter.") + @MXBeanDescription("MBeanROGetter.") public String getROData(); /** @@ -162,23 +162,23 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * @param someData Some data. * @return Some string. */ - @IgniteMXBeanDescription("MBeanSuperOperation.") - @IgniteMXBeanParametersNames({"someData"}) - @IgniteMXBeanParametersDescriptions({"MBeanOperationParameter1."}) + @MXBeanDescription("MBeanSuperOperation.") + @MXBeanParametersNames({"someData"}) + @MXBeanParametersDescriptions({"MBeanOperationParameter1."}) public String doSomethingSuper(String someData); } /** * Test MBean interface. */ - @IgniteMXBeanDescription("MBeanDescription.") + @MXBeanDescription("MBeanDescription.") public static interface GridMBeanInterface extends GridMBeanSuperInterface { /** * Test getter. * * @return Some string. */ - @IgniteMXBeanDescription("MBeanWritableGetter.") + @MXBeanDescription("MBeanWritableGetter.") public String getWritableData(); /** @@ -193,7 +193,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * * @return Some string. */ - @IgniteMXBeanDescription("MBeanReadonlyGetter.") + @MXBeanDescription("MBeanReadonlyGetter.") public String getReadOnlyData(); /** @@ -201,7 +201,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * * @return Some string. */ - @IgniteMXBeanDescription("MBeanWritableIsGetter.") + @MXBeanDescription("MBeanWritableIsGetter.") public boolean isWritable(); /** @@ -217,9 +217,9 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * @param someData Some data. * @return Some string. */ - @IgniteMXBeanDescription("MBeanOperation.") - @IgniteMXBeanParametersNames({"ignored", "someData"}) - @IgniteMXBeanParametersDescriptions({"MBeanOperationParameter1.", "MBeanOperationParameter2."}) + @MXBeanDescription("MBeanOperation.") + @MXBeanParametersNames({"ignored", "someData"}) + @MXBeanParametersDescriptions({"MBeanOperationParameter1.", "MBeanOperationParameter2."}) public String doSomething(boolean ignored, String someData); } @@ -234,9 +234,9 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * @param someData Some data. * @return Some string. */ - @IgniteMXBeanDescription("MBeanOperation.") - @IgniteMXBeanParametersNames({"ignored"}) - @IgniteMXBeanParametersDescriptions({"MBeanOperationParameter1.", "MBeanOperationParameter2."}) + @MXBeanDescription("MBeanOperation.") + @MXBeanParametersNames({"ignored"}) + @MXBeanParametersDescriptions({"MBeanOperationParameter1.", "MBeanOperationParameter2."}) public String doSomethingBad(boolean ignored, String someData); } @@ -251,7 +251,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * @param someData Some data. * @return Some string. */ - @IgniteMXBeanDescription("") + @MXBeanDescription("") public String doSomethingBad(boolean ignored, String someData); } @@ -266,7 +266,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * @param someData Some data. * @return Some string. */ - @IgniteMXBeanParametersNames({"", "someData"}) + @MXBeanParametersNames({"", "someData"}) public String doSomethingBadAgain(boolean ignored, String someData); } @@ -281,9 +281,9 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest { * @param someData Some data. * @return Some string. */ - @IgniteMXBeanDescription("MBeanOperation.") - @IgniteMXBeanParametersNames({"ignored", "someData"}) - @IgniteMXBeanParametersDescriptions({"MBeanOperationParameter1."}) + @MXBeanDescription("MBeanOperation.") + @MXBeanParametersNames({"ignored", "someData"}) + @MXBeanParametersDescriptions({"MBeanOperationParameter1."}) public String doSomethingBadAgain(boolean ignored, String someData); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c9b1dfb3/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpiMBean.java ---------------------------------------------------------------------- diff --git a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpiMBean.java b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpiMBean.java index 478d237..fb39f36 100644 --- a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpiMBean.java +++ b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpiMBean.java @@ -25,14 +25,14 @@ import java.util.*; /** * Management bean for {@link UriDeploymentSpi}. */ -@IgniteMXBeanDescription("MBean that provides access to URI deployment SPI configuration.") +@MXBeanDescription("MBean that provides access to URI deployment SPI configuration.") public interface UriDeploymentSpiMBean extends IgniteSpiManagementMBean { /** * Gets temporary directory path. * * @return Temporary directory path. */ - @IgniteMXBeanDescription("Temporary directory path.") + @MXBeanDescription("Temporary directory path.") public String getTemporaryDirectoryPath(); /** @@ -40,7 +40,7 @@ public interface UriDeploymentSpiMBean extends IgniteSpiManagementMBean { * * @return List of URIs. */ - @IgniteMXBeanDescription("List of URIs.") + @MXBeanDescription("List of URIs.") public List<String> getUriList(); /** @@ -48,6 +48,6 @@ public interface UriDeploymentSpiMBean extends IgniteSpiManagementMBean { * * @return if files are ckecked for redundancy. */ - @IgniteMXBeanDescription("Indicates if MD5 check is enabled.") + @MXBeanDescription("Indicates if MD5 check is enabled.") public boolean isCheckMd5(); }
