You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2017/06/14 18:39:07 UTC
[03/18] geode git commit: GEODE-2980: remove unnecessary explicit
keywords from interfaces
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java b/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java
index f6f701e..3e116fb 100644
--- a/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java
@@ -81,17 +81,17 @@ public interface DistributedSystemMXBean {
* @return The DistributedSystem ID or -1 if not set.
*/
@ResourceOperation()
- public int getDistributedSystemId();
+ int getDistributedSystemId();
/**
* Returns the number of members in the distributed system.
*/
- public int getMemberCount();
+ int getMemberCount();
/**
* Returns a list of names for all members.
*/
- public String[] listMembers();
+ String[] listMembers();
/**
* Returns a list of names for locator members.
@@ -101,49 +101,49 @@ public interface DistributedSystemMXBean {
* @return a list of names for locator members.
*/
- public String[] listLocatorMembers(boolean onlyStandAloneLocators);
+ String[] listLocatorMembers(boolean onlyStandAloneLocators);
/**
* Returns a list of names for all groups.
*/
- public String[] listGroups();
+ String[] listGroups();
/**
* Returns the number of locators in the distributed system.
*/
- public int getLocatorCount();
+ int getLocatorCount();
/**
* Returns a list of IDs for all locators.
*/
- public String[] listLocators(); // TODO - Abhishek Should be renamed to
- // listLocatorDiscoveryConfigurations? Do we need something for
- // mcast too?
+ String[] listLocators(); // TODO - Abhishek Should be renamed to
+ // listLocatorDiscoveryConfigurations? Do we need something for
+ // mcast too?
/**
* Returns the number of disks stores in the distributed system.
*/
- public int getSystemDiskStoreCount();
+ int getSystemDiskStoreCount();
/**
* Returns a map of all {@link DistributedMember}s and their {@link DiskStore}s.
*/
- public Map<String, String[]> listMemberDiskstore();
+ Map<String, String[]> listMemberDiskstore();
/**
* Returns a list of IDs for all gateway senders.
*/
- public String[] listGatewaySenders();
+ String[] listGatewaySenders();
/**
* Returns a list of IDs for all gateway receivers.
*/
- public String[] listGatewayReceivers();
+ String[] listGatewayReceivers();
/**
* Returns the minimum level set for alerts to be delivered to listeners.
*/
- public String getAlertLevel();
+ String getAlertLevel();
/**
* Sets the minimum level for alerts to be delivered to listeners.
@@ -152,74 +152,74 @@ public interface DistributedSystemMXBean {
* SEVERE or NONE.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.WRITE)
- public void changeAlertLevel(String alertLevel) throws Exception;
+ void changeAlertLevel(String alertLevel) throws Exception;
/**
* Returns the total available heap (in megabytes) across all distributed members.
*/
- public long getTotalHeapSize();
+ long getTotalHeapSize();
/**
* Returns the total number of entries in all regions.
*/
- public long getTotalRegionEntryCount();
+ long getTotalRegionEntryCount();
/**
* Returns the number of {@link Region}s.
*/
- public int getTotalRegionCount();
+ int getTotalRegionCount();
/**
* Returns the number of times that a cache miss occurred for all regions.
*/
- public int getTotalMissCount();
+ int getTotalMissCount();
/**
* Returns the number of times that a hit occurred for all regions.
*/
- public int getTotalHitCount();
+ int getTotalHitCount();
/**
* Returns the number of connected clients.
*/
- public int getNumClients();
+ int getNumClients();
/**
* Returns the average number of disk reads per second across all distributed members.
*/
- public float getDiskReadsRate();
+ float getDiskReadsRate();
/**
* Returns the average number of disk writes per second across all distributed members.
*/
- public float getDiskWritesRate();
+ float getDiskWritesRate();
/**
* Returns the average disk flush latency time.
*/
- public long getDiskFlushAvgLatency();
+ long getDiskFlushAvgLatency();
/**
* Returns the number of backups currently in progress for all disk stores.
*/
- public int getTotalBackupInProgress();
+ int getTotalBackupInProgress();
/**
* Returns the number of initial images in progress.
*/
- public int getNumInitialImagesInProgress();
+ int getNumInitialImagesInProgress();
/**
* Returns the number of active (currently executing) CQs for all cache servers.
*/
- public long getActiveCQCount();
+ long getActiveCQCount();
/**
* Returns the average number of queries per second across all distributed members.
*/
- public float getQueryRequestRate();
+ float getQueryRequestRate();
/**
* Performs a backup on all members.
@@ -229,8 +229,7 @@ public interface DistributedSystemMXBean {
* @return The results of the backup request.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.READ)
- public DiskBackupStatus backupAllMembers(String targetDirPath, String baselineDirPath)
- throws Exception;
+ DiskBackupStatus backupAllMembers(String targetDirPath, String baselineDirPath) throws Exception;
/**
* Returns the configuration information for a distributed member.
@@ -239,7 +238,7 @@ public interface DistributedSystemMXBean {
* @return The configuration information for a member.
* @throws Exception for an invalid member ID.
*/
- public GemFireProperties fetchMemberConfiguration(String member) throws Exception;
+ GemFireProperties fetchMemberConfiguration(String member) throws Exception;
/**
* Returns the total time (in seconds) since a distributed member was started.
@@ -248,21 +247,21 @@ public interface DistributedSystemMXBean {
* @return The total time (in seconds) since a member was started.
* @throws Exception for an invalid member ID.
*/
- public long fetchMemberUpTime(String member) throws Exception;
+ long fetchMemberUpTime(String member) throws Exception;
/**
* Returns a list of names for all cache servers which are able to serve requests from GemFire
* clients.
*
*/
- public String[] listCacheServers();
+ String[] listCacheServers();
/**
* Returns a list of names for all servers where server means any long-running GemFire process
* that was started with "start server" command from GFSH.
*/
- public String[] listServers();
+ String[] listServers();
/**
* Returns JVM metrics for a distributed member.
@@ -270,7 +269,7 @@ public interface DistributedSystemMXBean {
* @param member Name or ID of the member.
* @throws Exception for an invalid member ID.
*/
- public JVMMetrics showJVMMetrics(String member) throws Exception;
+ JVMMetrics showJVMMetrics(String member) throws Exception;
/**
* Returns operating system metrics for a distributed member.
@@ -278,7 +277,7 @@ public interface DistributedSystemMXBean {
* @param member Name or ID of the member.
* @throws Exception for an invalid member ID.
*/
- public OSMetrics showOSMetrics(String member) throws Exception;
+ OSMetrics showOSMetrics(String member) throws Exception;
/**
* Returns network metrics for a distributed member.
@@ -286,7 +285,7 @@ public interface DistributedSystemMXBean {
* @param member Name or ID of the member.
* @throws Exception for an invalid member ID.
*/
- public NetworkMetrics showNetworkMetric(String member) throws Exception;
+ NetworkMetrics showNetworkMetric(String member) throws Exception;
/**
* Returns disk metrics for a distributed member.
@@ -294,7 +293,7 @@ public interface DistributedSystemMXBean {
* @param member Name or ID of the member.
* @throws Exception for an invalid member ID.
*/
- public DiskMetrics showDiskMetrics(String member) throws Exception;
+ DiskMetrics showDiskMetrics(String member) throws Exception;
/**
* Shuts down all members of a distributed system except for the managing member.
@@ -302,17 +301,17 @@ public interface DistributedSystemMXBean {
* @return List of names of all distributed members that were shutdown.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE)
- public String[] shutDownAllMembers() throws Exception;
+ String[] shutDownAllMembers() throws Exception;
/**
* Returns a list of names for all regions.
*/
- public String[] listRegions();
+ String[] listRegions();
/**
* Returns a list of full paths for all regions.
*/
- public String[] listAllRegionPaths();
+ String[] listAllRegionPaths();
/**
* Removes a disk store from the distributed system.
@@ -321,39 +320,39 @@ public interface DistributedSystemMXBean {
* @return True if the request is successful, false otherwise.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public boolean revokeMissingDiskStores(String diskStoreId) throws Exception;
+ boolean revokeMissingDiskStores(String diskStoreId) throws Exception;
/**
* Returns a list of details for disk stores which have been determined to be unavailable during
* the recovery of region.
*/
- public PersistentMemberDetails[] listMissingDiskStores();
+ PersistentMemberDetails[] listMissingDiskStores();
/**
* Returns the object name for a {@link MemberMXBean} used to access this distributed member.
* allow anyone to access this method
*/
@ResourceOperation()
- public ObjectName getMemberObjectName();
+ ObjectName getMemberObjectName();
/**
* Returns the object name for a {@link ManagerMXBean} used to access the management service
* running on this distributed member.
*/
- public ObjectName getManagerObjectName();
+ ObjectName getManagerObjectName();
/**
* Returns a list of object names for the {@link MemberMXBean}s used to access all distributed
* members.
*/
- public ObjectName[] listMemberObjectNames();
+ ObjectName[] listMemberObjectNames();
/**
* Returns the object name for a {@link MemberMXBean} used to access a distributed member..
*
* @param member Name or ID of the member.
*/
- public ObjectName fetchMemberObjectName(String member) throws Exception;
+ ObjectName fetchMemberObjectName(String member) throws Exception;
/**
* Returns a list of object names for the {@link RegionMXBean}s used to access all regions on a
@@ -361,7 +360,7 @@ public interface DistributedSystemMXBean {
*
* @param memberMBeanName ObjectName of the member.
*/
- public ObjectName[] fetchRegionObjectNames(ObjectName memberMBeanName) throws Exception;
+ ObjectName[] fetchRegionObjectNames(ObjectName memberMBeanName) throws Exception;
/**
* Returns a list of object names for the {@link DistributedRegionMXBean}s used to access all
@@ -369,7 +368,7 @@ public interface DistributedSystemMXBean {
*
* @return An array of object names or an empty array if no distributed regions are found.
*/
- public ObjectName[] listDistributedRegionObjectNames();
+ ObjectName[] listDistributedRegionObjectNames();
/**
* Returns the object name for a {@link DistributedRegionMXBean} used to access a distributed
@@ -377,7 +376,7 @@ public interface DistributedSystemMXBean {
*
* @param regionPath Full path of the region.
*/
- public ObjectName fetchDistributedRegionObjectName(String regionPath) throws Exception;
+ ObjectName fetchDistributedRegionObjectName(String regionPath) throws Exception;
/**
* Returns the object name for a {@link RegionMXBean} used to access a region.
@@ -385,7 +384,7 @@ public interface DistributedSystemMXBean {
* @param member Name or ID of the member.
* @param regionPath Full path of the region.
*/
- public ObjectName fetchRegionObjectName(String member, String regionPath) throws Exception;
+ ObjectName fetchRegionObjectName(String member, String regionPath) throws Exception;
/**
* Returns the object name for a {@link GatewaySenderMXBean} used to access a gateway sender.
@@ -393,14 +392,14 @@ public interface DistributedSystemMXBean {
* @param member Name or ID of the member.
* @param senderId ID of a gateway sender.
*/
- public ObjectName fetchGatewaySenderObjectName(String member, String senderId) throws Exception;
+ ObjectName fetchGatewaySenderObjectName(String member, String senderId) throws Exception;
/**
* Returns the object name for a {@link GatewayReceiverMXBean} used to access a gateway receiver.
*
* @param member Name or ID of the member.
*/
- public ObjectName fetchGatewayReceiverObjectName(String member) throws Exception;
+ ObjectName fetchGatewayReceiverObjectName(String member) throws Exception;
/**
* Returns a list of object names for the {@link GatewaySenderMXBean}s used to access all gateway
@@ -408,7 +407,7 @@ public interface DistributedSystemMXBean {
*
* @return An array of object names or an empty array if no gateway senders are found.
*/
- public ObjectName[] listGatewaySenderObjectNames();
+ ObjectName[] listGatewaySenderObjectNames();
/**
* Returns a list of object names for the {@link GatewaySenderMXBean}s used to access all gateway
@@ -416,7 +415,7 @@ public interface DistributedSystemMXBean {
*
* @param member Name or ID of the member.
*/
- public ObjectName[] listGatewaySenderObjectNames(String member) throws Exception;
+ ObjectName[] listGatewaySenderObjectNames(String member) throws Exception;
/**
* Returns a list of object names for the {@link GatewayReceiverMXBean}s used to access all
@@ -424,7 +423,7 @@ public interface DistributedSystemMXBean {
*
* @return An array of object names or an empty array if no gateway receivers are found.
*/
- public ObjectName[] listGatewayReceiverObjectNames();
+ ObjectName[] listGatewayReceiverObjectNames();
/**
* Returns the object name for a {@link DistributedLockServiceMXBean} used to access a distributed
@@ -432,7 +431,7 @@ public interface DistributedSystemMXBean {
*
* @param lockServiceName Name of the lock service.
*/
- public ObjectName fetchDistributedLockServiceObjectName(String lockServiceName) throws Exception;
+ ObjectName fetchDistributedLockServiceObjectName(String lockServiceName) throws Exception;
/**
* Returns the object name for a {@link LockServiceMXBean} used to access a lock service.
@@ -440,7 +439,7 @@ public interface DistributedSystemMXBean {
* @param member Name or Id of the member.
* @param lockService Name of the lock service.
*/
- public ObjectName fetchLockServiceObjectName(String member, String lockService) throws Exception;
+ ObjectName fetchLockServiceObjectName(String member, String lockService) throws Exception;
/**
* Returns object name of a {@link DiskStoreMXBean} for a given name and member
@@ -450,7 +449,7 @@ public interface DistributedSystemMXBean {
* @return a ObjectName
* @throws Exception
*/
- public ObjectName fetchDiskStoreObjectName(String member, String diskStoreName) throws Exception;
+ ObjectName fetchDiskStoreObjectName(String member, String diskStoreName) throws Exception;
/**
* Returns the object name for a {@link CacheServerMXBean} used to access a cache server.
@@ -458,67 +457,67 @@ public interface DistributedSystemMXBean {
* @param member Name or ID of the member.
* @param port Port of the server.
*/
- public ObjectName fetchCacheServerObjectName(String member, int port) throws Exception;
+ ObjectName fetchCacheServerObjectName(String member, int port) throws Exception;
/**
* Returns a list of object names for the {@link CacheServerMXBean}s used to access all cache
* servers.
*/
- public ObjectName[] listCacheServerObjectNames();
+ ObjectName[] listCacheServerObjectNames();
/**
* Returns the number of map-reduce jobs currently running on all members in the distributed
* system.
*/
- public int getNumRunningFunctions();
+ int getNumRunningFunctions();
/**
* Returns the number of CQs registers on all members.
*/
- public long getRegisteredCQCount();
+ long getRegisteredCQCount();
/**
* Returns the number of bytes used on all disks.
*/
- public long getTotalDiskUsage();
+ long getTotalDiskUsage();
/**
* Returns the total heap used on all members.
*/
- public long getUsedHeapSize();
+ long getUsedHeapSize();
/**
* Returns the average number of reads per second for all members.
*/
- public float getAverageReads();
+ float getAverageReads();
/**
* Returns the average writes per second, including both put and putAll operations, for all
* members.
*/
- public float getAverageWrites();
+ float getAverageWrites();
/**
* Returns the number of subscriptions for all members.
*/
- public int getNumSubscriptions();
+ int getNumSubscriptions();
/**
* Returns the number of garbage collection operations for all members.
*/
- public long getGarbageCollectionCount();
+ long getGarbageCollectionCount();
/**
* Returns a map of remote distributed system IDs and the current connection status for each.
*/
- public Map<String, Boolean> viewRemoteClusterStatus();
+ Map<String, Boolean> viewRemoteClusterStatus();
/**
* Returns the number JVM pauses (which may or may not include full garbage collection pauses)
* detected by GemFire.
*/
- public long getJVMPauses();
+ long getJVMPauses();
/**
* This API is used to query data from GemFire system. This returns a JSON formated String having
@@ -551,7 +550,7 @@ public interface DistributedSystemMXBean {
* @return a JSON formated string containing data and its type
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.READ)
- public String queryData(String queryString, String members, int limit) throws Exception;
+ String queryData(String queryString, String members, int limit) throws Exception;
/**
*
@@ -575,7 +574,7 @@ public interface DistributedSystemMXBean {
* @return a byte[] which is a compressed JSON string.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.READ)
- public byte[] queryDataForCompressedResult(String queryString, String members, int limit)
+ byte[] queryDataForCompressedResult(String queryString, String members, int limit)
throws Exception;
@@ -583,31 +582,31 @@ public interface DistributedSystemMXBean {
* Returns the number of committed transactions across all members. It gives point in time value
* i.e. Number of tx committed at the time of reading this value
*/
- public int getTransactionCommitted();
+ int getTransactionCommitted();
/**
* Returns the number of transactions that were rolled back across all members. It gives point in
* time value i.e. Number of tx rolled back at the time of reading this value
*/
- public int getTransactionRolledBack();
+ int getTransactionRolledBack();
/**
* Number of rows DistributedSystemMXBean.queryData() operation will return. By default it will be
* 1000. User can modify this to control number of rows to be shown on Pulse, as Pulse DataBrowser
* internally uses DistributedSystemMXBean.queryData()
*/
- public int getQueryResultSetLimit();
+ int getQueryResultSetLimit();
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void setQueryResultSetLimit(int queryResultSetLimit);
+ void setQueryResultSetLimit(int queryResultSetLimit);
/**
* Number of elements in a collection to be shown in queryData operation if query results contain
* collections like Map, List etc.
*
*/
- public int getQueryCollectionsDepth();
+ int getQueryCollectionsDepth();
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void setQueryCollectionsDepth(int queryCollectionsDepth);
+ void setQueryCollectionsDepth(int queryCollectionsDepth);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java b/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java
index 749a743..24374e8 100644
--- a/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java
@@ -32,180 +32,180 @@ public interface GatewayReceiverMXBean {
/**
* Returns the port the receiver is listening on.
*/
- public int getPort();
+ int getPort();
/**
* Returns the configured buffer size of the socket connection.
*/
- public int getSocketBufferSize();
+ int getSocketBufferSize();
/**
* Returns the bind address on the host.
*/
- public String getBindAddress();
+ String getBindAddress();
/**
* Returns the maximum amount of time between client pings.
*/
- public int getMaximumTimeBetweenPings();
+ int getMaximumTimeBetweenPings();
/**
* Returns whether the receiver is in running state.
*
* @return True if the receiver is in a running state, false otherwise.
*/
- public boolean isRunning();
+ boolean isRunning();
/**
* Returns the instantaneous rate of events received.
*/
- public float getEventsReceivedRate();
+ float getEventsReceivedRate();
/**
* Returns the rate of create requests received.
*/
- public float getCreateRequestsRate();
+ float getCreateRequestsRate();
/**
* Returns the rate of update requests received.
*/
- public float getUpdateRequestsRate();
+ float getUpdateRequestsRate();
/**
* Returns the rate of destroy requests received.
*/
- public float getDestroyRequestsRate();
+ float getDestroyRequestsRate();
/**
* Returns the number of duplicate batches which have been received.
*/
- public int getDuplicateBatchesReceived();
+ int getDuplicateBatchesReceived();
/**
* Returns the number of batches which have been received out of order.
*/
- public int getOutoforderBatchesReceived();
+ int getOutoforderBatchesReceived();
/**
* Starts the gateway receiver.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void start() throws Exception;
+ void start() throws Exception;
/**
* Stops the gateway receiver.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void stop() throws Exception;
+ void stop() throws Exception;
/**
* Returns the configured start port.
*/
- public int getStartPort();
+ int getStartPort();
/**
* Returns the configured end port.
*/
- public int getEndPort();
+ int getEndPort();
/**
* Returns a list of names for the transport filters in use.
*/
- public String[] getGatewayTransportFilters();
+ String[] getGatewayTransportFilters();
/**
* Returns the number of sockets accepted and used for client to server messaging.
*/
- public int getClientConnectionCount();
+ int getClientConnectionCount();
/**
* Returns the number of client virtual machines connected and acting as a gateway.
*/
- public int getNumGateways();
+ int getNumGateways();
/**
* Returns the average get request latency.
*/
- public long getGetRequestAvgLatency();
+ long getGetRequestAvgLatency();
/**
* Returns the average put request latency.
*/
- public long getPutRequestAvgLatency();
+ long getPutRequestAvgLatency();
/**
* Returns the total number of client connections that timed out and were closed.
*/
- public int getTotalConnectionsTimedOut();
+ int getTotalConnectionsTimedOut();
/**
* Returns the total number of client connection requests that failed.
*/
- public int getTotalFailedConnectionAttempts();
+ int getTotalFailedConnectionAttempts();
/**
* Returns the current number of connections waiting for a thread to start processing their
* message.
*/
- public int getThreadQueueSize();
+ int getThreadQueueSize();
/**
* Returns the current number of threads handling a client connection.
*/
- public int getConnectionThreads();
+ int getConnectionThreads();
/**
* Returns the load from client to server connections as reported by the load probe installed in
* this server.
*/
- public double getConnectionLoad();
+ double getConnectionLoad();
/**
* Returns the estimate of how much load is added for each new connection as reported by the load
* probe installed in this server.
*/
- public double getLoadPerConnection();
+ double getLoadPerConnection();
/**
* Returns the load from queues as reported by the load probe installed in this server.
*/
- public double getQueueLoad();
+ double getQueueLoad();
/**
* Returns the estimate of how much load is added for each new queue as reported by the load probe
* installed in this server.
*/
- public double getLoadPerQueue();
+ double getLoadPerQueue();
/**
* Returns the rate of get requests.
*/
- public float getGetRequestRate();
+ float getGetRequestRate();
/**
* Returns the rate of put requests.
*/
- public float getPutRequestRate();
+ float getPutRequestRate();
/**
* Returns the total number of bytes sent to clients.
*/
- public long getTotalSentBytes();
+ long getTotalSentBytes();
/**
* Returns the total number of bytes received from clients.
*/
- public long getTotalReceivedBytes();
+ long getTotalReceivedBytes();
/**
* Returns a list of the host and port information for gateway senders connected to this gateway
* receiver.
*/
- public String[] getConnectedGatewaySenders();
+ String[] getConnectedGatewaySenders();
/**
* Returns the average batch processing time (in milliseconds).
*/
- public long getAverageBatchProcessingTime();
+ long getAverageBatchProcessingTime();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java b/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java
index 718a9be..6d97926 100644
--- a/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java
@@ -32,51 +32,51 @@ public interface GatewaySenderMXBean {
/**
* Returns the ID of the GatewaySender.
*/
- public String getSenderId();
+ String getSenderId();
/**
* Returns the id of the remote <code>GatewayReceiver</code>'s DistributedSystem.
*/
- public int getRemoteDSId();
+ int getRemoteDSId();
/**
* Returns the configured buffer size of the socket connection between this GatewaySender and its
* receiving <code>GatewayReceiver</code>.
*/
- public int getSocketBufferSize();
+ int getSocketBufferSize();
/**
* Returns the amount of time (in milliseconds) that a socket read between a sending GatewaySender
* and its receiving <code>GatewayReceiver</code> is allowed to block.
*/
- public long getSocketReadTimeout();
+ long getSocketReadTimeout();
/**
* Returns the name of the disk store that is used for persistence.
*/
- public String getOverflowDiskStoreName();
+ String getOverflowDiskStoreName();
/**
* Returns the maximum memory after which the data needs to be overflowed to disk.
*/
- public int getMaximumQueueMemory();
+ int getMaximumQueueMemory();
/**
* Returns the size of a batch that gets delivered by the GatewaySender.
*/
- public int getBatchSize();
+ int getBatchSize();
/**
* Returns the interval between transmissions by the GatewaySender.
*/
- public long getBatchTimeInterval();
+ long getBatchTimeInterval();
/**
* Returns whether batch conflation for the GatewaySender's queue is enabled
*
* @return True if batch conflation is enabled, false otherwise.
*/
- public boolean isBatchConflationEnabled();
+ boolean isBatchConflationEnabled();
/**
* Returns whether the GatewaySender is configured to be persistent or non-persistent.
@@ -84,81 +84,81 @@ public interface GatewaySenderMXBean {
* @return True if the sender is persistent, false otherwise.
*/
- public boolean isPersistenceEnabled();
+ boolean isPersistenceEnabled();
/**
* Returns the alert threshold for entries in a GatewaySender's queue.The default value is 0
* milliseconds in which case no alert will be logged if events are delayed in Queue.
*/
- public int getAlertThreshold();
+ int getAlertThreshold();
/**
* Returns a list of <code>GatewayEventFilter</code>s added to this GatewaySender.
*/
- public String[] getGatewayEventFilters();
+ String[] getGatewayEventFilters();
/**
* Returns a list of <code>GatewayTransportFilter</code>s added to this GatewaySender.
*/
- public String[] getGatewayTransportFilters();
+ String[] getGatewayTransportFilters();
/**
* Returns whether the GatewaySender is configured for manual start.
*
* @return True if the GatewaySender is configured for manual start, false otherwise.
*/
- public boolean isManualStart();
+ boolean isManualStart();
/**
* Returns whether or not this GatewaySender is running.
*
* @return True if the GatewaySender is running, false otherwise.
*/
- public boolean isRunning();
+ boolean isRunning();
/**
* Returns whether or not this GatewaySender is paused.
*
* @return True of the GatewaySender is paused, false otherwise.
*/
- public boolean isPaused();
+ boolean isPaused();
/**
* Returns the rate of events received per second by this Sender if it's a serial-wan.
*/
- public float getEventsReceivedRate();
+ float getEventsReceivedRate();
/**
* Returns the rate of events being queued.
*/
- public float getEventsQueuedRate();
+ float getEventsQueuedRate();
/**
* Returns the current size of the event queue.
*/
- public int getEventQueueSize();
+ int getEventQueueSize();
/**
* Returns the number of events received, but not added to the event queue, because the queue
* already contains an event with the same key.
*/
- public int getTotalEventsConflated();
+ int getTotalEventsConflated();
/**
* Returns the average number of batches sent per second.
*/
- public float getBatchesDispatchedRate();
+ float getBatchesDispatchedRate();
/**
* Returns the average time taken to send a batch of events.
*/
- public long getAverageDistributionTimePerBatch();
+ long getAverageDistributionTimePerBatch();
/**
* Returns the total number of batches of events that were resent.
*/
- public int getTotalBatchesRedistributed();
+ int getTotalBatchesRedistributed();
/**
* Starts this GatewaySender. Once the GatewaySender is running its configuration cannot be
@@ -166,80 +166,80 @@ public interface GatewaySenderMXBean {
*
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void start();
+ void start();
/**
* Stops this GatewaySender.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void stop();
+ void stop();
/**
* Pauses this GatewaySender.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void pause();
+ void pause();
/**
* Resumes this paused GatewaySender.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void resume();
+ void resume();
/**
* Rebalances this GatewaySender.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void rebalance();
+ void rebalance();
/**
* Returns whether this GatewaySender is primary or secondary.
*
* @return True if this is the primary, false otherwise.
*/
- public boolean isPrimary();
+ boolean isPrimary();
/**
* Returns the number of dispatcher threads working for this <code>GatewaySender</code>.
*/
- public int getDispatcherThreads();
+ int getDispatcherThreads();
/**
* Returns the order policy followed while dispatching the events to remote distributed system.
* Order policy is only relevant when the number of dispatcher threads is greater than one.
*/
- public String getOrderPolicy();
+ String getOrderPolicy();
/**
* Returns whether the isDiskSynchronous property is set for this GatewaySender.
*
* @return True if the property is set, false otherwise.
*/
- public boolean isDiskSynchronous();
+ boolean isDiskSynchronous();
/**
* Returns whether the isParallel property is set for this GatewaySender.
*
* @return True if the property is set, false otherwise.
*/
- public boolean isParallel();
+ boolean isParallel();
/**
* Returns the host and port information of GatewayReceiver to which this gateway sender is
* connected.
*/
- public String getGatewayReceiver();
+ String getGatewayReceiver();
/**
* Returns whether this GatewaySender is connected and sending data to a GatewayReceiver.
*/
- public boolean isConnected();
+ boolean isConnected();
/**
* Returns number of events which have exceeded the configured alert threshold.
*/
- public int getEventsExceedingAlertThreshold();
+ int getEventsExceedingAlertThreshold();
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/JMXNotificationType.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/JMXNotificationType.java b/geode-core/src/main/java/org/apache/geode/management/JMXNotificationType.java
index ba3daeb..5eed3b1 100644
--- a/geode-core/src/main/java/org/apache/geode/management/JMXNotificationType.java
+++ b/geode-core/src/main/java/org/apache/geode/management/JMXNotificationType.java
@@ -30,28 +30,28 @@ public interface JMXNotificationType {
* Notification type which indicates that a region has been created in the cache <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.region.created</CODE>.
*/
- public static final String REGION_CREATED =
+ String REGION_CREATED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.region.created";
/**
* Notification type which indicates that a region has been closed/destroyed in the cache <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.region.closed</CODE>.
*/
- public static final String REGION_CLOSED =
+ String REGION_CLOSED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.region.closed";
/**
* Notification type which indicates that a disk store has been created <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.disk.created</CODE>.
*/
- public static final String DISK_STORE_CREATED =
+ String DISK_STORE_CREATED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.disk.created";
/**
* Notification type which indicates that a disk store has been closed. <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.disk.closed</CODE>.
*/
- public static final String DISK_STORE_CLOSED =
+ String DISK_STORE_CLOSED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.disk.closed";
/**
@@ -59,7 +59,7 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.cache.lockservice.created</CODE>.
*/
- public static final String LOCK_SERVICE_CREATED =
+ String LOCK_SERVICE_CREATED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.lockservice.created";
/**
@@ -67,28 +67,28 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.cache.lockservice.closed</CODE>.
*/
- public static final String LOCK_SERVICE_CLOSED =
+ String LOCK_SERVICE_CLOSED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.lockservice.closed";
/**
* Notification type which indicates that a member has been added to the system. <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.created</CODE>.
*/
- public static final String CACHE_MEMBER_JOINED =
+ String CACHE_MEMBER_JOINED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.member.joined";
/**
* Notification type which indicates that a member has departed from the system. <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.created</CODE>.
*/
- public static final String CACHE_MEMBER_DEPARTED =
+ String CACHE_MEMBER_DEPARTED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.member.departed";
/**
* Notification type which indicates that a member is suspected. <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.created</CODE>.
*/
- public static final String CACHE_MEMBER_SUSPECT =
+ String CACHE_MEMBER_SUSPECT =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.member.suspect";
/**
@@ -96,7 +96,7 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.cacheserver.client.joined</CODE>.
*/
- public static final String CLIENT_JOINED =
+ String CLIENT_JOINED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cacheserver.client.joined";
/**
@@ -104,7 +104,7 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.cacheserver.client.left</CODE>.
*/
- public static final String CLIENT_LEFT =
+ String CLIENT_LEFT =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cacheserver.client.left";
/**
@@ -112,7 +112,7 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.cacheserver.client.crashed</CODE>.
*/
- public static final String CLIENT_CRASHED =
+ String CLIENT_CRASHED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cacheserver.client.crashed";
/**
@@ -120,42 +120,42 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.gateway.receiver.created</CODE>.
*/
- public static final String GATEWAY_RECEIVER_CREATED =
+ String GATEWAY_RECEIVER_CREATED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.receiver.created";
/**
* Notification type which indicates that a gateway sender is created <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.gateway.sender.created</CODE>.
*/
- public static final String GATEWAY_SENDER_CREATED =
+ String GATEWAY_SENDER_CREATED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.sender.created";
/**
* Notification type which indicates that a gateway sender is started <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.gateway.sender.started</CODE>.
*/
- public static final String GATEWAY_SENDER_STARTED =
+ String GATEWAY_SENDER_STARTED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.sender.started";
/**
* Notification type which indicates that a gateway sender is stopped <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.gateway.sender.stopped</CODE>.
*/
- public static final String GATEWAY_SENDER_STOPPED =
+ String GATEWAY_SENDER_STOPPED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.sender.stopped";
/**
* Notification type which indicates that a gateway sender is paused <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.gateway.sender.paused</CODE>.
*/
- public static final String GATEWAY_SENDER_PAUSED =
+ String GATEWAY_SENDER_PAUSED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.sender.paused";
/**
* Notification type which indicates that a gateway sender is resumed <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.gateway.sender.resumed</CODE>.
*/
- public static final String GATEWAY_SENDER_RESUMED =
+ String GATEWAY_SENDER_RESUMED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.sender.resumed";
/**
@@ -163,7 +163,7 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>ggemfire.distributedsystem.asycn.event.queue.created</CODE>.
*/
- public static final String ASYNC_EVENT_QUEUE_CREATED =
+ String ASYNC_EVENT_QUEUE_CREATED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.asycn.event.queue.created";
/**
@@ -171,27 +171,27 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.async.event.queue.closed</CODE>.
*/
- public static final String ASYNC_EVENT_QUEUE_CLOSED =
+ String ASYNC_EVENT_QUEUE_CLOSED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.async.event.queue.closed";
/**
* Notification type which indicates a GemFire system generated alert <BR>
* The value of this type string is <CODE>system.alert</CODE>.
*/
- public static final String SYSTEM_ALERT = "system.alert";
+ String SYSTEM_ALERT = "system.alert";
/**
* Notification type which indicates that cache server is started <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.server.started</CODE>.
*/
- public static final String CACHE_SERVER_STARTED =
+ String CACHE_SERVER_STARTED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.server.started";
/**
* Notification type which indicates that cache server is stopped <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.server.stopped</CODE>.
*/
- public static final String CACHE_SERVER_STOPPED =
+ String CACHE_SERVER_STOPPED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.server.stopped";
/**
@@ -199,7 +199,7 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.gateway.receiver.started</CODE>.
*/
- public static final String GATEWAY_RECEIVER_STARTED =
+ String GATEWAY_RECEIVER_STARTED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.receiver.started";
/**
@@ -207,20 +207,19 @@ public interface JMXNotificationType {
* The value of this type string is
* <CODE>gemfire.distributedsystem.gateway.receiver.stopped</CODE>.
*/
- public static final String GATEWAY_RECEIVER_STOPPED =
+ String GATEWAY_RECEIVER_STOPPED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.gateway.receiver.stopped";
/**
* Notification type which indicates that locator is started <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.locator.started</CODE>.
*/
- public static final String LOCATOR_STARTED =
- DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.locator.started";
+ String LOCATOR_STARTED = DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.locator.started";
/**
* Notification type which indicates that a cache service is created <BR>
* The value of this type string is <CODE>gemfire.distributedsystem.cache.service.created</CODE>.
*/
- public static final String CACHE_SERVICE_CREATED =
+ String CACHE_SERVICE_CREATED =
DistributionConfig.GEMFIRE_PREFIX + "distributedsystem.cache.service.created";
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/JMXNotificationUserData.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/JMXNotificationUserData.java b/geode-core/src/main/java/org/apache/geode/management/JMXNotificationUserData.java
index 30d6d67..06ff062 100644
--- a/geode-core/src/main/java/org/apache/geode/management/JMXNotificationUserData.java
+++ b/geode-core/src/main/java/org/apache/geode/management/JMXNotificationUserData.java
@@ -24,7 +24,7 @@ public interface JMXNotificationUserData {
/**
* The level at which this alert is issued.
*/
- public static final String ALERT_LEVEL = "AlertLevel";
+ String ALERT_LEVEL = "AlertLevel";
/**
* The member of the distributed system that issued the alert, or null if the issuer is no longer
@@ -32,12 +32,12 @@ public interface JMXNotificationUserData {
* org.apache.geode.management.UserData
*/
- public static final String MEMBER = "Member";
+ String MEMBER = "Member";
/**
* The thread causing the alert
*/
- public static final String THREAD = "Thread";
+ String THREAD = "Thread";
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/LocatorMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/LocatorMXBean.java b/geode-core/src/main/java/org/apache/geode/management/LocatorMXBean.java
index c5cb659..2277d4e 100644
--- a/geode-core/src/main/java/org/apache/geode/management/LocatorMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/LocatorMXBean.java
@@ -30,46 +30,46 @@ public interface LocatorMXBean {
/**
* Returns the port on which this Locator listens for connections.
*/
- public int getPort();
+ int getPort();
/**
* Returns a string representing the IP address or host name that this Locator will listen on.
*/
- public String getBindAddress();
+ String getBindAddress();
/**
* Returns the name or IP address to pass to the client as the location where the Locator is
* listening.
*/
- public String getHostnameForClients();
+ String getHostnameForClients();
/**
* Returns whether the Locator provides peer location services to members.
*
* @return True if the Locator provides peer locations services, false otherwise.
*/
- public boolean isPeerLocator();
+ boolean isPeerLocator();
/**
* Returns whether the Locator provides server location services To clients.
*
* @return True if the Locator provides server location services, false otherwise.
*/
- public boolean isServerLocator();
+ boolean isServerLocator();
/**
* Returns the most recent log entries for the Locator.
*/
- public String viewLog();
+ String viewLog();
/**
* Returns a list of servers on which the manager service may be started either by a Locator or
* users.
*/
- public String[] listPotentialManagers();
+ String[] listPotentialManagers();
/**
* Returns the list of current managers.
*/
- public String[] listManagers();
+ String[] listManagers();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java b/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java
index f109022..3d25f04 100644
--- a/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java
@@ -35,53 +35,53 @@ public interface LockServiceMXBean {
/**
* Returns the name of the lock service.
*/
- public String getName();
+ String getName();
/**
* Returns whether this is a distributed LockService.
*
* @return True is this is a distributed LockService, false otherwise.
*/
- public boolean isDistributed();
+ boolean isDistributed();
/**
* Returns the number of members using this LockService.
*/
- public int getMemberCount();
+ int getMemberCount();
/**
* Returns of the name of the member which grants the lock.
*/
- public String fetchGrantorMember();
+ String fetchGrantorMember();
/**
* Returns a list of names of the members using this LockService.
*/
- public String[] getMemberNames();
+ String[] getMemberNames();
/**
* Returns whether this member is the granter.
*
* @return True if this member is the granter, false otherwise.
*/
- public boolean isLockGrantor();
+ boolean isLockGrantor();
/**
* Requests that this member become the granter.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void becomeLockGrantor();
+ void becomeLockGrantor();
/**
* Returns a map of the names of the objects being locked on and the names of the threads holding
* the locks.
*/
- public Map<String, String> listThreadsHoldingLock();
+ Map<String, String> listThreadsHoldingLock();
/**
* Returns a list of names of the locks held by this member's threads.
*/
- public String[] listHeldLocks();
+ String[] listHeldLocks();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/ManagerMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/ManagerMXBean.java b/geode-core/src/main/java/org/apache/geode/management/ManagerMXBean.java
index 606bac4..d63f1f5 100644
--- a/geode-core/src/main/java/org/apache/geode/management/ManagerMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/ManagerMXBean.java
@@ -35,7 +35,7 @@ public interface ManagerMXBean {
*
* @return True of the manager service is running, false otherwise.
*/
- public boolean isRunning();
+ boolean isRunning();
/**
* Starts the manager service.
@@ -43,7 +43,7 @@ public interface ManagerMXBean {
* @return True if the manager service was successfully started, false otherwise.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE)
- public boolean start() throws JMException;
+ boolean start() throws JMException;
/**
* Stops the manager service.
@@ -51,12 +51,12 @@ public interface ManagerMXBean {
* @return True if the manager service was successfully stopped, false otherwise.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE)
- public boolean stop() throws JMException;
+ boolean stop() throws JMException;
/**
* Returns the URL for connecting to the Pulse application.
*/
- public String getPulseURL();
+ String getPulseURL();
/**
* Sets the URL for the Pulse application.
@@ -64,14 +64,14 @@ public interface ManagerMXBean {
* @param pulseURL The URL for the Pulse application.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.WRITE)
- public void setPulseURL(String pulseURL);
+ void setPulseURL(String pulseURL);
/**
* Returns the last set status message. Generally, a subcomponent will call setStatusMessage to
* save the result of its execution. For example, if the embedded HTTP server failed to start, the
* reason for that failure will be saved here.
*/
- public String getStatusMessage();
+ String getStatusMessage();
/**
* Sets the status message.
@@ -79,5 +79,5 @@ public interface ManagerMXBean {
* @param message The status message.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.WRITE)
- public void setStatusMessage(String message);
+ void setStatusMessage(String message);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java b/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java
index e2de400..4a02ac8 100644
--- a/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java
@@ -143,7 +143,7 @@ public interface MemberMXBean {
*
* @param numberOfLines Number of lines to return, up to a maximum of 100.
*/
- public String showLog(int numberOfLines);
+ String showLog(int numberOfLines);
/**
* Returns the license string for this member.
@@ -151,7 +151,7 @@ public interface MemberMXBean {
* @deprecated Removed licensing in 8.0.
*/
@Deprecated
- public String viewLicense();
+ String viewLicense();
/**
* Performs compaction on all of the member's disk stores.
@@ -159,7 +159,7 @@ public interface MemberMXBean {
* @return A list of names of the disk stores that were compacted.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public String[] compactAllDiskStores();
+ String[] compactAllDiskStores();
/**
* Creates a Manager MBean on this member.
@@ -167,24 +167,24 @@ public interface MemberMXBean {
* @return True if the Manager MBean was successfully created, false otherwise.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE)
- public boolean createManager();
+ boolean createManager();
/**
* Shuts down the member. This is an asynchronous call and it will return immediately without
* waiting for a result.
*/
@ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE)
- public void shutDownMember();
+ void shutDownMember();
/**
* Returns JVM metrics.
*/
- public JVMMetrics showJVMMetrics();
+ JVMMetrics showJVMMetrics();
/**
* Returns operating system metrics.
*/
- public OSMetrics showOSMetrics();
+ OSMetrics showOSMetrics();
/**
* Executes a command on the member.
@@ -222,89 +222,89 @@ public interface MemberMXBean {
*
* @param includeRegionOwned Whether to include disk stores owned by a region.
*/
- public String[] listDiskStores(boolean includeRegionOwned);
+ String[] listDiskStores(boolean includeRegionOwned);
/**
* Returns the GemFire specific properties for this member.
*/
- public GemFireProperties listGemFireProperties();
+ GemFireProperties listGemFireProperties();
/**
* Returns the name or IP address of the host on which this member is running.
*/
- public String getHost();
+ String getHost();
/**
* Returns the name of this member.
*/
- public String getName();
+ String getName();
/**
* Returns the ID of this member.
*/
- public String getId();
+ String getId();
/**
* Returns the name of the member if it's been set, otherwise the ID.
*/
- public String getMember();
+ String getMember();
/**
* Returns the names of the groups this member belongs to.
*/
- public String[] getGroups();
+ String[] getGroups();
/**
* Returns the operating system process ID.
*/
- public int getProcessId();
+ int getProcessId();
/**
* Returns the status.
*/
- public String status();
+ String status();
/**
* Returns the GemFire version.
*/
- public String getVersion();
+ String getVersion();
/**
* Returns whether this member is attached to at least one Locator.
*
* @return True if this member is attached to a Locator, false otherwise.
*/
- public boolean isLocator();
+ boolean isLocator();
/**
* Returns the number of seconds that this member will wait for a distributed lock.
*/
- public long getLockTimeout();
+ long getLockTimeout();
/**
* Returns the number of second that this member will lease a distributed lock.
*/
- public long getLockLease();
+ long getLockLease();
/**
* Any long-running GemFire process that was started with "start server" command from GFSH. It
* returns true even if that process has --disable-default-server=true.
*/
- public boolean isServer();
+ boolean isServer();
/**
* Returns whether this member has at least one GatewaySender.
*
* @return True if this member has at least one GatwaySender, false otherwise.
*/
- public boolean hasGatewaySender();
+ boolean hasGatewaySender();
/**
* Returns whether this member is running the Manager service.
*
* @return True if this member is running the Manager service, false otherwise.
*/
- public boolean isManager();
+ boolean isManager();
/**
* Returns whether this member has created the Manager service (it may be created, but not
@@ -312,29 +312,29 @@ public interface MemberMXBean {
*
* @return True if this member has created the Manager service, false otherwise.
*/
- public boolean isManagerCreated();
+ boolean isManagerCreated();
/**
* Returns whether this member has at least one GatewayReceiver.
*
* @return True if this member has at least one GatwayReceiver, false otherwise.
*/
- public boolean hasGatewayReceiver();
+ boolean hasGatewayReceiver();
/**
* Returns the ClassPath.
*/
- public String getClassPath();
+ String getClassPath();
/**
* Returns the current time on the member's host.
*/
- public long getCurrentTime();
+ long getCurrentTime();
/**
* Returns the number of seconds that this member has been running.
*/
- public long getMemberUpTime();
+ long getMemberUpTime();
/**
* Returns the time (as a percentage) that this member's process time with respect to Statistics
@@ -345,393 +345,393 @@ public interface MemberMXBean {
* the platform it will be shown as -1
*
*/
- public float getCpuUsage();
+ float getCpuUsage();
/**
* Returns the current size of the heap in megabytes.
*
* @deprecated Please use {@link #getUsedMemory()} instead.
*/
- public long getCurrentHeapSize();
+ long getCurrentHeapSize();
/**
* Returns the maximum size of the heap in megabytes.
*
* @deprecated Please use {@link #getMaxMemory()} instead.
*/
- public long getMaximumHeapSize();
+ long getMaximumHeapSize();
/**
* Returns the free heap size in megabytes.
*
* @deprecated Please use {@link #getFreeMemory()} instead.
*/
- public long getFreeHeapSize();
+ long getFreeHeapSize();
/**
* Returns the maximum size of the heap in megabytes.
*
*/
- public long getMaxMemory();
+ long getMaxMemory();
/**
* Returns the free heap size in megabytes.
*/
- public long getFreeMemory();
+ long getFreeMemory();
/**
* Returns the current size of the heap in megabytes.
*/
- public long getUsedMemory();
+ long getUsedMemory();
/**
* Returns the current threads.
*/
- public String[] fetchJvmThreads();
+ String[] fetchJvmThreads();
/**
* Returns the maximum number of open file descriptors allowed for the member's host operating
* system.
*/
- public long getFileDescriptorLimit();
+ long getFileDescriptorLimit();
/**
* Returns the current number of open file descriptors.
*/
- public long getTotalFileDescriptorOpen();
+ long getTotalFileDescriptorOpen();
/**
* Returns the number of Regions present in the Cache.
*/
- public int getTotalRegionCount();
+ int getTotalRegionCount();
/**
* Returns the number of Partition Regions present in the Cache.
*/
- public int getPartitionRegionCount();
+ int getPartitionRegionCount();
/**
* Returns a list of all Region names.
*/
- public String[] listRegions();
+ String[] listRegions();
/**
* Returns a list of all disk stores, including those owned by a Region.
*/
- public String[] getDiskStores();
+ String[] getDiskStores();
/**
* Returns a list of all root Region names.
*/
- public String[] getRootRegionNames();
+ String[] getRootRegionNames();
/**
* Returns the total number of entries in all regions.
*/
- public int getTotalRegionEntryCount();
+ int getTotalRegionEntryCount();
/**
* Returns the total number of buckets.
*/
- public int getTotalBucketCount();
+ int getTotalBucketCount();
/**
* Returns the number of buckets for which this member is the primary holder.
*/
- public int getTotalPrimaryBucketCount();
+ int getTotalPrimaryBucketCount();
/**
* Returns the cache get average latency.
*/
- public long getGetsAvgLatency();
+ long getGetsAvgLatency();
/**
* Returns the cache put average latency.
*/
- public long getPutsAvgLatency();
+ long getPutsAvgLatency();
/**
* Returns the cache putAll average latency.
*/
- public long getPutAllAvgLatency();
+ long getPutAllAvgLatency();
/**
* Returns the number of times that a cache miss occurred for all regions.
*/
- public int getTotalMissCount();
+ int getTotalMissCount();
/**
* Returns the number of times that a hit occurred for all regions.
*/
- public int getTotalHitCount();
+ int getTotalHitCount();
/**
* Returns the number of gets per second.
*/
- public float getGetsRate();
+ float getGetsRate();
/**
* Returns the number of puts per second. Only includes puts done explicitly on this member's
* cache, not those pushed from another member.
*/
- public float getPutsRate();
+ float getPutsRate();
/**
* Returns the number of putAlls per second.
*/
- public float getPutAllRate();
+ float getPutAllRate();
/**
* Returns the number of creates per second.
*/
- public float getCreatesRate();
+ float getCreatesRate();
/**
* Returns the number of destroys per second.
*/
- public float getDestroysRate();
+ float getDestroysRate();
/**
* Returns the average latency of a call to a CacheWriter.
*/
- public long getCacheWriterCallsAvgLatency();
+ long getCacheWriterCallsAvgLatency();
/**
* Returns the average latency of a call to a CacheListener.
*/
- public long getCacheListenerCallsAvgLatency();
+ long getCacheListenerCallsAvgLatency();
/**
* Returns the total number of times that a load on this cache has completed, as a result of
* either a local get or a remote net load.
*/
- public int getTotalLoadsCompleted();
+ int getTotalLoadsCompleted();
/**
* Returns the average latency of a load.
*/
- public long getLoadsAverageLatency();
+ long getLoadsAverageLatency();
/**
* Returns the total number of times the a network load initiated by this cache has completed.
*/
- public int getTotalNetLoadsCompleted();
+ int getTotalNetLoadsCompleted();
/**
* Returns the net load average latency.
*/
- public long getNetLoadsAverageLatency();
+ long getNetLoadsAverageLatency();
/**
* Returns the total number of times that a network search initiated by this cache has completed.
*/
- public int getTotalNetSearchCompleted();
+ int getTotalNetSearchCompleted();
/**
* Returns the net search average latency.
*/
- public long getNetSearchAverageLatency();
+ long getNetSearchAverageLatency();
/**
* Returns the current number of disk tasks (op-log compaction, asynchronous recovery, etc.) that
* are waiting for a thread to run.
*/
- public int getTotalDiskTasksWaiting();
+ int getTotalDiskTasksWaiting();
/**
* Returns the average number of bytes per second sent.
*/
- public float getBytesSentRate();
+ float getBytesSentRate();
/**
* Returns the average number of bytes per second received.
*/
- public float getBytesReceivedRate();
+ float getBytesReceivedRate();
/**
* Returns a list of IDs for all connected gateway receivers.
*/
- public String[] listConnectedGatewayReceivers();
+ String[] listConnectedGatewayReceivers();
/**
* Returns a list of IDs for all gateway senders.
*/
- public String[] listConnectedGatewaySenders();
+ String[] listConnectedGatewaySenders();
/**
* Returns the number of currently executing functions.
*/
- public int getNumRunningFunctions();
+ int getNumRunningFunctions();
/**
* Returns the average function execution rate.
*/
- public float getFunctionExecutionRate();
+ float getFunctionExecutionRate();
/**
* Returns the number of currently executing functions that will return resutls.
*/
- public int getNumRunningFunctionsHavingResults();
+ int getNumRunningFunctionsHavingResults();
/**
* Returns the number of current transactions.
*/
- public int getTotalTransactionsCount();
+ int getTotalTransactionsCount();
/**
* Returns the average commit latency in nanoseconds .
*/
- public long getTransactionCommitsAvgLatency();
+ long getTransactionCommitsAvgLatency();
/**
* Returns the number of committed transactions.
*/
- public int getTransactionCommittedTotalCount();
+ int getTransactionCommittedTotalCount();
/**
* Returns the number of transactions that were rolled back.
*/
- public int getTransactionRolledBackTotalCount();
+ int getTransactionRolledBackTotalCount();
/**
* Returns the average number of transactions committed per second.
*/
- public float getTransactionCommitsRate();
+ float getTransactionCommitsRate();
/**
* Returns the number of bytes reads per second from all the disks of the member.
*/
- public float getDiskReadsRate();
+ float getDiskReadsRate();
/**
* Returns the number of bytes written per second to disk to all the disks of the member.
*/
- public float getDiskWritesRate();
+ float getDiskWritesRate();
/**
* Returns the average disk flush latency time in nanoseconds.
*/
- public long getDiskFlushAvgLatency();
+ long getDiskFlushAvgLatency();
/**
* Returns the number of backups currently in progress for all disk stores.
*/
- public int getTotalBackupInProgress();
+ int getTotalBackupInProgress();
/**
* Returns the number of backups that have been completed.
*/
- public int getTotalBackupCompleted();
+ int getTotalBackupCompleted();
/**
* Returns the number of threads waiting for a lock.
*/
- public int getLockWaitsInProgress();
+ int getLockWaitsInProgress();
/**
* Returns the amount of time (in milliseconds) spent waiting for a lock.
*/
- public long getTotalLockWaitTime();
+ long getTotalLockWaitTime();
/**
* Returns the number of lock services in use.
*/
- public int getTotalNumberOfLockService();
+ int getTotalNumberOfLockService();
/**
* Returns the number of locks for which this member is a granter.
*/
- public int getTotalNumberOfGrantors();
+ int getTotalNumberOfGrantors();
/**
* Returns the number of lock request queues in use by this member.
*/
- public int getLockRequestQueues();
+ int getLockRequestQueues();
/**
* Returns the entry eviction rate as triggered by the LRU policy.
*/
- public float getLruEvictionRate();
+ float getLruEvictionRate();
/**
* Returns the rate of entries destroyed either by destroy cache operations or eviction.
*/
- public float getLruDestroyRate();
+ float getLruDestroyRate();
/**
* Returns the number of initial images in progress.
*/
- public int getInitialImagesInProgres();
+ int getInitialImagesInProgres();
/**
* Returns the total amount of time spent performing a "get initial image" operation when creating
* a region.
*/
- public long getInitialImageTime();
+ long getInitialImageTime();
/**
* Return the number of keys received while performing a "get initial image" operation when
* creating a region.
*/
- public int getInitialImageKeysReceived();
+ int getInitialImageKeysReceived();
/**
* Returns the average time (in nanoseconds) spent deserializing objects. Includes
* deserializations that result in a PdxInstance.
*/
- public long getDeserializationAvgLatency();
+ long getDeserializationAvgLatency();
/**
* Returns the average latency (in nanoseconds) spent deserializing objects. Includes
* deserializations that result in a PdxInstance.
*/
- public long getDeserializationLatency();
+ long getDeserializationLatency();
/**
* Returns the instantaneous rate of deserializing objects. Includes deserializations that result
* in a PdxInstance.
*/
- public float getDeserializationRate();
+ float getDeserializationRate();
/**
* Returns the average time (in nanoseconds) spent serializing objects. Includes serializations
* that result in a PdxInstance.
*/
- public long getSerializationAvgLatency();
+ long getSerializationAvgLatency();
/**
* Returns the average latency (in nanoseconds) spent serializing objects. Includes serializations
* that result in a PdxInstance.
*/
- public long getSerializationLatency();
+ long getSerializationLatency();
/**
* Returns the instantaneous rate of serializing objects. Includes serializations that result in a
* PdxInstance.
*/
- public float getSerializationRate();
+ float getSerializationRate();
/**
* Returns the instantaneous rate of PDX instance deserialization.
*/
- public float getPDXDeserializationRate();
+ float getPDXDeserializationRate();
/**
* Returns the average time, in seconds, spent deserializing PDX instanced.
*/
- public long getPDXDeserializationAvgLatency();
+ long getPDXDeserializationAvgLatency();
/**
* Returns the total number of bytes used on all disks.
*/
- public long getTotalDiskUsage();
+ long getTotalDiskUsage();
/**
* Returns the number of threads in use.
*/
- public int getNumThreads();
+ int getNumThreads();
/**
* Returns the system load average for the last minute. The system load average is the sum of the
@@ -742,99 +742,99 @@ public interface MemberMXBean {
*
* @return The load average or a negative value if one is not available.
*/
- public double getLoadAverage();
+ double getLoadAverage();
/**
* Returns the number of times garbage collection has occurred.
*/
- public long getGarbageCollectionCount();
+ long getGarbageCollectionCount();
/**
* Returns the amount of time (in milliseconds) spent on garbage collection.
*/
- public long getGarbageCollectionTime();
+ long getGarbageCollectionTime();
/**
* Returns the average number of reads per second.
*/
- public float getAverageReads();
+ float getAverageReads();
/**
* Returns the average writes per second, including both put and putAll operations.
*/
- public float getAverageWrites();
+ float getAverageWrites();
/**
* Returns the number JVM pauses (which may or may not include full garbage collection pauses)
* detected by GemFire.
*/
- public long getJVMPauses();
+ long getJVMPauses();
/**
* Returns the underlying host's current cpuActive percentage
*/
- public int getHostCpuUsage();
+ int getHostCpuUsage();
/**
*
* Returns true if a cache server is running on this member and able server requests from GemFire
* clients
*/
- public boolean isCacheServer();
+ boolean isCacheServer();
/**
* Returns the redundancy-zone of the member;
*/
- public String getRedundancyZone();
+ String getRedundancyZone();
/**
* Returns current number of cache rebalance operations being directed by this process.
*/
- public int getRebalancesInProgress();
+ int getRebalancesInProgress();
/**
* Returns current number of threads waiting for a reply.
*/
- public int getReplyWaitsInProgress();
+ int getReplyWaitsInProgress();
/**
* Returns total number of times waits for a reply have completed.
*/
- public int getReplyWaitsCompleted();
+ int getReplyWaitsCompleted();
/**
* The current number of nodes in this distributed system visible to this member.
*/
- public int getVisibleNodes();
+ int getVisibleNodes();
/**
* Returns the number of off heap objects.
*/
- public int getOffHeapObjects();
+ int getOffHeapObjects();
/**
* Returns the size of the maximum configured off-heap memory in bytes.
*/
- public long getOffHeapMaxMemory();
+ long getOffHeapMaxMemory();
/**
* Returns the size of available (or unallocated) off-heap memory in bytes.
*/
- public long getOffHeapFreeMemory();
+ long getOffHeapFreeMemory();
/**
* Returns the size of utilized off-heap memory in bytes.
*/
- public long getOffHeapUsedMemory();
+ long getOffHeapUsedMemory();
/**
* Returns the percentage of off-heap memory fragmentation.
*/
- public int getOffHeapFragmentation();
+ int getOffHeapFragmentation();
/**
* Returns the total time spent compacting in millseconds.
*/
- public long getOffHeapCompactionTime();
+ long getOffHeapCompactionTime();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/RegionMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/RegionMXBean.java b/geode-core/src/main/java/org/apache/geode/management/RegionMXBean.java
index a2c8eb1..6886eac 100644
--- a/geode-core/src/main/java/org/apache/geode/management/RegionMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/RegionMXBean.java
@@ -38,161 +38,161 @@ public interface RegionMXBean {
/**
* Returns the name of the Region.
*/
- public String getName();
+ String getName();
/**
* Returns the type (data policy) of the Region.
*/
- public String getRegionType();
+ String getRegionType();
/**
* Returns the full path of the Region.
*/
- public String getFullPath();
+ String getFullPath();
/**
* The name of the parent Region or <code>null</code> if the Region has no parent.
*/
- public String getParentRegion();
+ String getParentRegion();
/**
* Returns a list of the names of the sub regions.
*
* @param recursive <code>True</code> to recursively traverse and find sub-regions.
*/
- public String[] listSubregionPaths(boolean recursive);
+ String[] listSubregionPaths(boolean recursive);
/**
* Returns the attributes of the Region.
*/
- public RegionAttributesData listRegionAttributes();
+ RegionAttributesData listRegionAttributes();
/**
* Returns the partition attributes of the Region.
*/
- public PartitionAttributesData listPartitionAttributes();
+ PartitionAttributesData listPartitionAttributes();
/**
* Returns the fixed partition attributes of the Region.
*/
- public FixedPartitionAttributesData[] listFixedPartitionAttributes();
+ FixedPartitionAttributesData[] listFixedPartitionAttributes();
/**
* Returns the eviction attributes of the Region.
*/
- public EvictionAttributesData listEvictionAttributes();
+ EvictionAttributesData listEvictionAttributes();
/**
* Returns the membership attributes of the Region.
*
* @deprecated this API is scheduled to be removed
*/
- public MembershipAttributesData listMembershipAttributes();
+ MembershipAttributesData listMembershipAttributes();
/**
* Returns the time of the most recent modification. For partitioned region it will be -1 . This
* feature is not supported for partitioned regions.
*/
- public long getLastModifiedTime();
+ long getLastModifiedTime();
/**
* Returns the time of the most recent access. For partitioned region it will be -1. This feature
* is not supported for partitioned regions.
*/
- public long getLastAccessedTime();
+ long getLastAccessedTime();
/**
* Returns the number of times that a cache miss occurred. For partitioned region it will be -1 .
* This feature is not supported for partitioned regions.
*/
- public long getMissCount();
+ long getMissCount();
/**
* Returns the number of times that a hit occurred. For partitioned region it will be -1.This
* feature is not supported for partitioned regions.
*/
- public long getHitCount();
+ long getHitCount();
/**
* Returns the hit to miss ratio. For partitioned region it will be -1 .This feature is not
* supported for partitioned regions.
*/
- public float getHitRatio();
+ float getHitRatio();
/**
* Returns the number of entries in the Region within this member. For partitioned regions it will
* be the entry count for the primary buckets hosted within this member.
*
*/
- public long getEntryCount();
+ long getEntryCount();
/**
* Returns the number of gets per second.
*/
- public float getGetsRate();
+ float getGetsRate();
/**
* Returns the number of puts per second.
*/
- public float getPutsRate();
+ float getPutsRate();
/**
* Returns the number of creates per second.
*/
- public float getCreatesRate();
+ float getCreatesRate();
/**
* Returns the number of destroys per second.
*/
- public float getDestroyRate();
+ float getDestroyRate();
/**
* Returns the number of putAlls per second.
*/
- public float getPutAllRate();
+ float getPutAllRate();
/**
* Returns the number of local puts per second.Only applicable for partitioned regions.
*/
- public float getPutLocalRate();
+ float getPutLocalRate();
/**
* Returns the number of remote puts per second.Only applicable for partitioned regions.
*/
- public float getPutRemoteRate();
+ float getPutRemoteRate();
/**
* Returns the latency for the most recent remote put in nanoseconds.Only applicable for
* partitioned regions.
*/
- public long getPutRemoteLatency();
+ long getPutRemoteLatency();
/**
* Returns the average latency for remote puts in nanoseconds.Only applicable for partitioned
* regions.
*/
- public long getPutRemoteAvgLatency();
+ long getPutRemoteAvgLatency();
/**
* Returns the current number of entries whose values are only on disk (not in memory). Entries
* may not exist in memory if they have been overflowed to disk or not yet been faulted in after a
* recovery.
*/
- public long getTotalEntriesOnlyOnDisk();
+ long getTotalEntriesOnlyOnDisk();
/**
* Returns the current number of entries held in memory.
*/
- public long getTotalDiskEntriesInVM();
+ long getTotalDiskEntriesInVM();
/**
* Returns the number of entries reads per second from disk.
*/
- public float getDiskReadsRate();
+ float getDiskReadsRate();
/**
@@ -200,24 +200,24 @@ public interface RegionMXBean {
*
* @deprecated See corresponding DiskStores latency to get the latency.
*/
- public long getDiskReadsAverageLatency();
+ long getDiskReadsAverageLatency();
/**
* Returns the average latency of disk writes in nanoseconds.
*
* @deprecated See corresponding DiskStores latency to get the latency.
*/
- public long getDiskWritesAverageLatency();
+ long getDiskWritesAverageLatency();
/**
* Returns the number of entries written per second to disk.
*/
- public float getDiskWritesRate();
+ float getDiskWritesRate();
/**
* Returns the current number of disk writes in progress.
*/
- public long getTotalDiskWritesProgress();
+ long getTotalDiskWritesProgress();
/**
* Returns the current number of disk tasks (op-log compaction, asynchronous recoveries, etc) that
@@ -225,49 +225,49 @@ public interface RegionMXBean {
*
* @deprecated
*/
- public long getDiskTaskWaiting();
+ long getDiskTaskWaiting();
/**
* Returns the average latency of a call to a {@link CacheWriter} in nanoseconds.
*/
- public long getCacheWriterCallsAvgLatency();
+ long getCacheWriterCallsAvgLatency();
/**
* Returns the average latency of a call to a {@link CacheListener} in nanoseconds.
*/
- public long getCacheListenerCallsAvgLatency();
+ long getCacheListenerCallsAvgLatency();
/**
* Returns the entry eviction rate as triggered by the LRU policy.
*/
- public float getLruEvictionRate();
+ float getLruEvictionRate();
/**
* Returns the rate of entries destroyed either by destroy cache operations or eviction.
*/
- public float getLruDestroyRate();
+ float getLruDestroyRate();
/**
* Returns the number of buckets on this member. Only applicable for partitioned regions.
*/
- public int getBucketCount();
+ int getBucketCount();
/**
* Returns the number of primary buckets on this member. Only applicable for partitioned regions.
*/
- public int getPrimaryBucketCount();
+ int getPrimaryBucketCount();
/**
* Returns the number of buckets without full redundancy. Only applicable for partitioned regions.
*/
- public int getNumBucketsWithoutRedundancy();
+ int getNumBucketsWithoutRedundancy();
/**
* Returns the number of redundant copies configured for this partitioned region.Only applicable
* for partitioned regions.
*/
- public int getConfiguredRedundancy();
+ int getConfiguredRedundancy();
/**
* Returns the actual number of redundant copies available for buckets in this partitioned region.
@@ -276,25 +276,25 @@ public interface RegionMXBean {
* less than the configured number. In that case, the value returned will be the smallest number
* of redundant copies available for any single bucket.
*/
- public int getActualRedundancy();
+ int getActualRedundancy();
/**
* Returns the total number of entries in all buckets. Only applicable for partitioned regions.
*/
- public int getTotalBucketSize();
+ int getTotalBucketSize();
/**
* Returns the average number of entries in bucket. Only applicable for partitioned regions.
*
* @deprecated This attribute is removed from 8.0 for being incorrect and impacting performance.
*/
- public int getAvgBucketSize();
+ int getAvgBucketSize();
/**
* Returns the total number of bytes stored in disk for this region.
*/
- public long getDiskUsage();
+ long getDiskUsage();
/**
* Returns the aggregate entry size (in bytes) of all entries. This will provide a correct value
@@ -304,40 +304,40 @@ public interface RegionMXBean {
* the secondary entries in the data store. So while referring to size one should take redundancy
* into account
*/
- public long getEntrySize();
+ long getEntrySize();
/**
* Returns whether this region sends data using a GatewaySender.
*/
- public boolean isGatewayEnabled();
+ boolean isGatewayEnabled();
/**
* Returns the average number of read requests per second.
*/
- public float getAverageReads();
+ float getAverageReads();
/**
* Returns the average number of write requests per second. This include rates of put,putAll &
* create operations on the region
*/
- public float getAverageWrites();
+ float getAverageWrites();
/**
* Returns whether persistence is enabled.
*/
- public boolean isPersistentEnabled();
+ boolean isPersistentEnabled();
/**
* Returns the name/ID of the member hosting this Region.
*/
- public String getMember();
+ String getMember();
/**
* Returns the maximum amount of local memory that can be used by the region. This attribute is
* applicable for PartitionedRegion only. For other regions it will be -1
*/
- public int getLocalMaxMemory();
+ int getLocalMaxMemory();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/cli/CliMetaData.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/cli/CliMetaData.java b/geode-core/src/main/java/org/apache/geode/management/cli/CliMetaData.java
index 226086f..15162a8 100644
--- a/geode-core/src/main/java/org/apache/geode/management/cli/CliMetaData.java
+++ b/geode-core/src/main/java/org/apache/geode/management/cli/CliMetaData.java
@@ -32,10 +32,10 @@ import java.lang.annotation.Target;
public @interface CliMetaData {
/** Represents a default value to an option of a command. **/
- public static final String ANNOTATION_DEFAULT_VALUE = "__DEFAULT__";
+ String ANNOTATION_DEFAULT_VALUE = "__DEFAULT__";
/** Represents a null value to an option of a command. **/
- public static final String ANNOTATION_NULL_VALUE = "__NULL__";
+ String ANNOTATION_NULL_VALUE = "__NULL__";
/**
* Indicates that the command will only run in the gfsh shell Gfsh ExecutionStrategy will use this
@@ -84,7 +84,7 @@ public @interface CliMetaData {
*/
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
- public @interface AvailabilityMetadata {
+ @interface AvailabilityMetadata {
/**
* String describing the availability condition.
*/
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/management/cli/CommandStatement.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/cli/CommandStatement.java b/geode-core/src/main/java/org/apache/geode/management/cli/CommandStatement.java
index a01f08c..f68a86b 100755
--- a/geode-core/src/main/java/org/apache/geode/management/cli/CommandStatement.java
+++ b/geode-core/src/main/java/org/apache/geode/management/cli/CommandStatement.java
@@ -28,19 +28,19 @@ public interface CommandStatement {
/**
* Returns the user specified command string.
*/
- public String getCommandString();
+ String getCommandString();
/**
* Returns the CLI environment variables.
*/
- public Map<String, String> getEnv();
+ Map<String, String> getEnv();
/**
* Processes this command statement with the user specified command string and environment
*
* @return The {@link Result} of the execution of this command statement.
*/
- public Result process();
+ Result process();
/**
@@ -48,5 +48,5 @@ public interface CommandStatement {
*
* @return True if the command statement is well formed, false otherwise.
*/
- public boolean validate();
+ boolean validate();
}