http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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/7c7b577e/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(); }
