http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/StatisticsTypeFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/StatisticsTypeFactory.java b/geode-core/src/main/java/org/apache/geode/StatisticsTypeFactory.java index d37e2c2..ee9a2ff 100644 --- a/geode-core/src/main/java/org/apache/geode/StatisticsTypeFactory.java +++ b/geode-core/src/main/java/org/apache/geode/StatisticsTypeFactory.java @@ -95,83 +95,83 @@ public interface StatisticsTypeFactory { * <code>name</code>, <code>description</code>, <code>units</code>, and with larger values * indicating better performance. */ - public StatisticDescriptor createIntCounter(String name, String description, String units); + StatisticDescriptor createIntCounter(String name, String description, String units); /** * Creates and returns a long counter {@link StatisticDescriptor} with the given * <code>name</code>, <code>description</code>, <code>units</code>, and with larger values * indicating better performance. */ - public StatisticDescriptor createLongCounter(String name, String description, String units); + StatisticDescriptor createLongCounter(String name, String description, String units); /** * Creates and returns a double counter {@link StatisticDescriptor} with the given * <code>name</code>, <code>description</code>, <code>units</code>, and with larger values * indicating better performance. */ - public StatisticDescriptor createDoubleCounter(String name, String description, String units); + StatisticDescriptor createDoubleCounter(String name, String description, String units); /** * Creates and returns an int gauge {@link StatisticDescriptor} with the given <code>name</code>, * <code>description</code>, <code>units</code>, and with smaller values indicating better * performance. */ - public StatisticDescriptor createIntGauge(String name, String description, String units); + StatisticDescriptor createIntGauge(String name, String description, String units); /** * Creates and returns a long gauge {@link StatisticDescriptor} with the given <code>name</code>, * <code>description</code>, <code>units</code>, and with smaller values indicating better * performance. */ - public StatisticDescriptor createLongGauge(String name, String description, String units); + StatisticDescriptor createLongGauge(String name, String description, String units); /** * Creates and returns a double gauge {@link StatisticDescriptor} with the given * <code>name</code>, <code>description</code>, <code>units</code>, and with smaller values * indicating better performance. */ - public StatisticDescriptor createDoubleGauge(String name, String description, String units); + StatisticDescriptor createDoubleGauge(String name, String description, String units); /** * Creates and returns an int counter {@link StatisticDescriptor} with the given * <code>name</code>, <code>description</code>, <code>largerBetter</code>, and <code>units</code>. */ - public StatisticDescriptor createIntCounter(String name, String description, String units, + StatisticDescriptor createIntCounter(String name, String description, String units, boolean largerBetter); /** * Creates and returns a long counter {@link StatisticDescriptor} with the given * <code>name</code>, <code>description</code>, <code>largerBetter</code>, and <code>units</code>. */ - public StatisticDescriptor createLongCounter(String name, String description, String units, + StatisticDescriptor createLongCounter(String name, String description, String units, boolean largerBetter); /** * Creates and returns a double counter {@link StatisticDescriptor} with the given * <code>name</code>, <code>description</code>, <code>largerBetter</code>, and <code>units</code>. */ - public StatisticDescriptor createDoubleCounter(String name, String description, String units, + StatisticDescriptor createDoubleCounter(String name, String description, String units, boolean largerBetter); /** * Creates and returns an int gauge {@link StatisticDescriptor} with the given <code>name</code>, * <code>description</code>, <code>largerBetter</code>, and <code>units</code>. */ - public StatisticDescriptor createIntGauge(String name, String description, String units, + StatisticDescriptor createIntGauge(String name, String description, String units, boolean largerBetter); /** * Creates and returns a long gauge {@link StatisticDescriptor} with the given <code>name</code>, * <code>description</code>, <code>largerBetter</code>, and <code>units</code>. */ - public StatisticDescriptor createLongGauge(String name, String description, String units, + StatisticDescriptor createLongGauge(String name, String description, String units, boolean largerBetter); /** * Creates and returns a double gauge {@link StatisticDescriptor} with the given * <code>name</code>, <code>description</code>, <code>largerBetter</code>, and <code>units</code>. */ - public StatisticDescriptor createDoubleGauge(String name, String description, String units, + StatisticDescriptor createDoubleGauge(String name, String description, String units, boolean largerBetter); @@ -180,7 +180,7 @@ public interface StatisticsTypeFactory { * <P> * Current value is: <code>254</code> */ - public final int MAX_DESCRIPTORS_PER_TYPE = StatArchiveFormat.ILLEGAL_STAT_OFFSET - 1; + int MAX_DESCRIPTORS_PER_TYPE = StatArchiveFormat.ILLEGAL_STAT_OFFSET - 1; /** * Creates or finds and returns a {@link StatisticsType} with the given <code>name</code>, @@ -189,13 +189,13 @@ public interface StatisticsTypeFactory { * @throws IllegalArgumentException if a type with the given <code>name</code> already exists and * it differs from the given parameters. */ - public StatisticsType createType(String name, String description, StatisticDescriptor[] stats); + StatisticsType createType(String name, String description, StatisticDescriptor[] stats); /** * Finds and returns an already created {@link StatisticsType} with the given <code>name</code>. * Returns <code>null</code> if the type does not exist. */ - public StatisticsType findType(String name); + StatisticsType findType(String name); /** * Creates one or more {@link StatisticsType} from the contents of the given <code>reader</code>. @@ -207,5 +207,5 @@ public interface StatisticsTypeFactory { * @throws IllegalArgumentException if a type defined in the reader already exists * @throws IOException Something went wrong while reading from <code>reader</code> */ - public StatisticsType[] createTypesFromXml(Reader reader) throws IOException; + StatisticsType[] createTypesFromXml(Reader reader) throws IOException; }
http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java b/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java index cd4dc7e..7629765 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java +++ b/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java @@ -42,33 +42,33 @@ public interface AdminDistributedSystem { /** * Retrieves the unique id for this system. */ - public String getId(); + String getId(); /** * Retrieves display friendly name for this system. If this administrative VM defined an optional * name for its connection to the distributed system, that name will be returned. Otherwise the * returned value will be {@link org.apache.geode.admin.AdminDistributedSystem#getId}. */ - public String getName(); + String getName(); /** * Retrieves the remote command and formatting this system should use to access and/or manipulate * resources on remote machines. */ - public String getRemoteCommand(); + String getRemoteCommand(); /** * Sets the remote command and formatting this system should use to access and/or manipulate * resources on remote machines. */ - public void setRemoteCommand(String remoteCommand); + void setRemoteCommand(String remoteCommand); /** * Sets the lowest level of alert that should be delivered to the {@link AlertListener}s * registered on this <code>AdminDistributedSystem</code>. The default level is * {@link AlertLevel#WARNING}. */ - public void setAlertLevel(AlertLevel level); + void setAlertLevel(AlertLevel level); /** * Returns the lowest level of alerts that should be delivered to the {@link AlertListener}s @@ -76,14 +76,14 @@ public interface AdminDistributedSystem { * * @see #setAlertLevel */ - public AlertLevel getAlertLevel(); + AlertLevel getAlertLevel(); /** * Sets the lowest level of alert that should be delivered to the {@link AlertListener}s * registered on this <code>AdminDistributedSystem</code>. The default level is * {@link AlertLevel#WARNING}. */ - public void setAlertLevelAsString(String level); + void setAlertLevelAsString(String level); /** * Returns the lowest level of alerts that should be delivered to the {@link AlertListener}s @@ -91,75 +91,75 @@ public interface AdminDistributedSystem { * * @see #setAlertLevelAsString */ - public String getAlertLevelAsString(); + String getAlertLevelAsString(); /** * Registers an <code>AlertListener</code> that will receive all alerts that are at or above the * {@linkplain #setAlertLevel alert level}. */ - public void addAlertListener(AlertListener listener); + void addAlertListener(AlertListener listener); /** * Unregisters an <code>AlertListener</code> */ - public void removeAlertListener(AlertListener listener); + void removeAlertListener(AlertListener listener); /** * Retrieves the multicast address in use by this system. */ - public String getMcastAddress(); + String getMcastAddress(); /** * Retrieves the multicast port in use by this system. */ - public int getMcastPort(); + int getMcastPort(); /** * Retrieves comma-delimited list locators to be used if multi-cast port is zero. Format of each * locators must be host[port]. */ - public String getLocators(); + String getLocators(); /** * Returns true if this system has enabled the use of multicast for communications */ - public boolean isMcastEnabled(); + boolean isMcastEnabled(); /** * Returns true if any members of this system are currently running. */ - public boolean isRunning(); + boolean isRunning(); /** * Returns <code>true</code> if this is currently connected to the system. */ - public boolean isConnected(); + boolean isConnected(); /** * Starts all managed entities that are not currently running. * * @throws AdminException If a problem is encountered while starting the managed entities. */ - public void start() throws AdminException; + void start() throws AdminException; /** * Stops all managed entities that are currently running. * * @throws AdminException If a problem is encountered while starting the managed entities. */ - public void stop() throws AdminException; + void stop() throws AdminException; /** * Merges and returns all system logs as a single formatted log. */ - public String displayMergedLogs(); + String displayMergedLogs(); /** * Retrieves the license information for this installation of GemFire. * * @deprecated Removed licensing in 8.0. */ - public java.util.Properties getLicense(); + java.util.Properties getLicense(); /** * Creates a new <code>DistributionLocator</code> that is ready to @@ -171,30 +171,30 @@ public interface AdminDistributedSystem { * system. That is, the host/port of the new locator is appended to the {@link #getLocators * locators} attribute of this <code>AdminDistributedSystem</code>. */ - public DistributionLocator addDistributionLocator(); + DistributionLocator addDistributionLocator(); /** * Returns array of <code>DistributionLocator</code>s administered by this * <code>AdminDistributedSystem</code>. */ - public DistributionLocator[] getDistributionLocators(); + DistributionLocator[] getDistributionLocators(); /** * Retrieves SystemMember instances for every application that is running and currently connection * to this system. Note that this list does not include dedicated {@linkplain #getCacheVms cache * server vms}. */ - public SystemMember[] getSystemMemberApplications() throws org.apache.geode.admin.AdminException; + SystemMember[] getSystemMemberApplications() throws org.apache.geode.admin.AdminException; /** * Display in readable format the latest Alert in this distributed system. */ - public String getLatestAlert(); + String getLatestAlert(); /** * Returns an object for monitoring the health of GemFire. */ - public GemFireHealth getGemFireHealth(); + GemFireHealth getGemFireHealth(); /** * Connects to the distributed system. This method will return immediately after spawning a @@ -207,7 +207,7 @@ public interface AdminDistributedSystem { * @see #isRunning * @see #waitToBeConnected */ - public void connect(); + void connect(); /** * Wait for up to a given number of milliseconds for the connection to the distributed system to @@ -220,28 +220,28 @@ public interface AdminDistributedSystem { * @throws InterruptedException If the thread invoking this method is interrupted while waiting. * @throws IllegalStateException If {@link #connect} has not yet been called. */ - public boolean waitToBeConnected(long timeout) throws InterruptedException; + boolean waitToBeConnected(long timeout) throws InterruptedException; /** * Disconnects from the distributed system. */ - public void disconnect(); + void disconnect(); /** Returns this system's configuration . */ - public DistributedSystemConfig getConfig(); + DistributedSystemConfig getConfig(); /** * Registers a listener that receives callbacks when a member joins or leaves the distributed * system. */ - public void addMembershipListener(SystemMembershipListener listener); + void addMembershipListener(SystemMembershipListener listener); /** * Unregisters a membership listener * * @see #addMembershipListener */ - public void removeMembershipListener(SystemMembershipListener listener); + void removeMembershipListener(SystemMembershipListener listener); /** * Registers a cache event listener. Does nothing if the listener is already registered. The @@ -250,7 +250,7 @@ public interface AdminDistributedSystem { * @param listener the listener to register. * @since GemFire 5.0 */ - public void addCacheListener(SystemMemberCacheListener listener); + void addCacheListener(SystemMemberCacheListener listener); /** * Unregisters a cache listener. Does nothing if the listener is not registered. @@ -258,7 +258,7 @@ public interface AdminDistributedSystem { * @param listener the listener to unregister. * @since GemFire 5.0 */ - public void removeCacheListener(SystemMemberCacheListener listener); + void removeCacheListener(SystemMemberCacheListener listener); /** * Creates a new cache server that is ready to {@linkplain CacheServerConfig configure} and @@ -268,7 +268,7 @@ public interface AdminDistributedSystem { * @deprecated as of 5.7 use {@link #addCacheVm} instead. */ @Deprecated - public CacheServer addCacheServer() throws AdminException; + CacheServer addCacheServer() throws AdminException; /** * Returns all of the dedicated cache server members of the distributed system. Because they are @@ -278,7 +278,7 @@ public interface AdminDistributedSystem { * @deprecated as of 5.7 use {@link #getCacheVms} instead. */ @Deprecated - public CacheServer[] getCacheServers() throws AdminException; + CacheServer[] getCacheServers() throws AdminException; /** * Returns all the cache server members of the distributed system which are hosting a client queue @@ -290,7 +290,7 @@ public interface AdminDistributedSystem { * * @since GemFire 5.6 */ - public CacheServer[] getCacheServers(String durableClientId) throws AdminException; + CacheServer[] getCacheServers(String durableClientId) throws AdminException; /** * Creates a new cache vm that is ready to {@linkplain CacheVmConfig configure} and @@ -298,7 +298,7 @@ public interface AdminDistributedSystem { * * @since GemFire 5.7 */ - public CacheVm addCacheVm() throws AdminException; + CacheVm addCacheVm() throws AdminException; /** * Returns all of the dedicated cache server vm members of the distributed system. Because they @@ -307,7 +307,7 @@ public interface AdminDistributedSystem { * * @since GemFire 5.7 */ - public CacheVm[] getCacheVms() throws AdminException; + CacheVm[] getCacheVms() throws AdminException; /** * Returns the administrative SystemMember specified by the @@ -317,7 +317,7 @@ public interface AdminDistributedSystem { * @return administrative SystemMember for that distributed member * @since GemFire 5.0 */ - public SystemMember lookupSystemMember(DistributedMember distributedMember) throws AdminException; + SystemMember lookupSystemMember(DistributedMember distributedMember) throws AdminException; /** * Indicate to the distributed system that persistent files have been lost. When a member recovers @@ -330,7 +330,7 @@ public interface AdminDistributedSystem { * @since GemFire 6.5 * @deprecated use {@link #revokePersistentMember(UUID)} instead */ - public void revokePersistentMember(InetAddress host, String directory) throws AdminException; + void revokePersistentMember(InetAddress host, String directory) throws AdminException; /** * Indicate to the distributed system that persistent files have been lost. When a member recovers @@ -343,7 +343,7 @@ public interface AdminDistributedSystem { * * @since GemFire 7.0 */ - public void revokePersistentMember(UUID diskStoreID) throws AdminException; + void revokePersistentMember(UUID diskStoreID) throws AdminException; /** * Retrieve the set of persistent files that the existing members are waiting for. See @@ -355,7 +355,7 @@ public interface AdminDistributedSystem { * @since GemFire 6.5 * */ - public Set<PersistentID> getMissingPersistentMembers() throws AdminException; + Set<PersistentID> getMissingPersistentMembers() throws AdminException; /** * Shuts down all the members of the distributed system with a cache that the admin member is @@ -372,7 +372,7 @@ public interface AdminDistributedSystem { * @return The set of members that were shutdown * @since GemFire 6.5 */ - public Set<DistributedMember> shutDownAllMembers() throws AdminException; + Set<DistributedMember> shutDownAllMembers() throws AdminException; /** * Shuts down all the members of the distributed system with a cache that the admin member is @@ -389,7 +389,7 @@ public interface AdminDistributedSystem { * * @since GemFire 6.5 */ - public Set<DistributedMember> shutDownAllMembers(long timeout) throws AdminException; + Set<DistributedMember> shutDownAllMembers(long timeout) throws AdminException; /** * Backup the persistent files for all of the members of the distributed system that the admin @@ -401,7 +401,7 @@ public interface AdminDistributedSystem { * set of members that were known to be offline at the time of backup. * @since GemFire 6.5 */ - public BackupStatus backupAllMembers(File targetDir) throws AdminException; + BackupStatus backupAllMembers(File targetDir) throws AdminException; /** * Incrementally backup the persistent files for all of the members of the distributed system that @@ -418,7 +418,7 @@ public interface AdminDistributedSystem { * set of members that were known to be offline at the time of backup. * @since GemFire 6.5 */ - public BackupStatus backupAllMembers(File targetDir, File baselineDir) throws AdminException; + BackupStatus backupAllMembers(File targetDir, File baselineDir) throws AdminException; /** * Compact the persistent files for all of the members of the distributed system that the admin @@ -429,6 +429,6 @@ public interface AdminDistributedSystem { * @return The set of members that compacted their disk stores. * @since GemFire 6.5 */ - public Map<DistributedMember, Set<PersistentID>> compactAllDiskStores() throws AdminException; + Map<DistributedMember, Set<PersistentID>> compactAllDiskStores() throws AdminException; } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/Alert.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/Alert.java b/geode-core/src/main/java/org/apache/geode/admin/Alert.java index 44c373e..ba20335 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/Alert.java +++ b/geode-core/src/main/java/org/apache/geode/admin/Alert.java @@ -27,27 +27,27 @@ package org.apache.geode.admin; public interface Alert { /** The level at which this alert is issued */ - public AlertLevel getLevel(); + AlertLevel getLevel(); /** * The member of the distributed system that issued the alert, or null if the issuer is no longer * a member of the distributed system. */ - public SystemMember getSystemMember(); + SystemMember getSystemMember(); /** * The name of the {@linkplain org.apache.geode.distributed.DistributedSystem#getName distributed * system}) through which the alert was issued. */ - public String getConnectionName(); + String getConnectionName(); /** The id of the source of the alert (such as a thread in a VM) */ - public String getSourceId(); + String getSourceId(); /** The alert's message */ - public String getMessage(); + String getMessage(); /** The time at which the alert was issued */ - public java.util.Date getDate(); + java.util.Date getDate(); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java b/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java index 247f4d0..4c5a169 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java +++ b/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java @@ -26,5 +26,5 @@ public interface AlertListener extends java.util.EventListener { /** * Invoked when an <code>Alert</code> is received. */ - public void alert(Alert alert); + void alert(Alert alert); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java index 9f99309..61689f7 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java @@ -70,21 +70,21 @@ public interface CacheHealthConfig { * The default maximum number of milliseconds a <code>netSearch</code> operation can take before * the cache member is considered to be unhealthy. */ - public static final long DEFAULT_MAX_NET_SEARCH_TIME = 60 * 1000; + long DEFAULT_MAX_NET_SEARCH_TIME = 60 * 1000; /** * The default maximum mumber of milliseconds a cache <code>load</code> operation can take before * the cache member is considered to be unhealthy. */ - public static final long DEFAULT_MAX_LOAD_TIME = 60 * 1000; + long DEFAULT_MAX_LOAD_TIME = 60 * 1000; /** The default minimum hit ratio of a healthy cache member. */ - public static final double DEFAULT_MIN_HIT_RATIO = 0.0; + double DEFAULT_MIN_HIT_RATIO = 0.0; /** * The default maximum number of entries in the event delivery queue of a healthy cache member. */ - public static final long DEFAULT_MAX_EVENT_QUEUE_SIZE = 1000; + long DEFAULT_MAX_EVENT_QUEUE_SIZE = 1000; /////////////////////// Instance Methods /////////////////////// @@ -94,7 +94,7 @@ public interface CacheHealthConfig { * * @see #DEFAULT_MAX_NET_SEARCH_TIME */ - public long getMaxNetSearchTime(); + long getMaxNetSearchTime(); /** * Sets the maximum number of milliseconds a <code>netSearch</code> operation can take before the @@ -102,7 +102,7 @@ public interface CacheHealthConfig { * * @see #getMaxNetSearchTime */ - public void setMaxNetSearchTime(long maxNetSearchTime); + void setMaxNetSearchTime(long maxNetSearchTime); /** * Returns the maximum mumber of milliseconds a cache <code>load</code> operation can take before @@ -110,7 +110,7 @@ public interface CacheHealthConfig { * * @see #DEFAULT_MAX_LOAD_TIME */ - public long getMaxLoadTime(); + long getMaxLoadTime(); /** * Sets the maximum mumber of milliseconds a cache <code>load</code> operation can take before the @@ -118,34 +118,34 @@ public interface CacheHealthConfig { * * @see #getMaxLoadTime */ - public void setMaxLoadTime(long maxLoadTime); + void setMaxLoadTime(long maxLoadTime); /** * Returns the minimum hit ratio of a healthy cache member. * * @see #DEFAULT_MIN_HIT_RATIO */ - public double getMinHitRatio(); + double getMinHitRatio(); /** * Sets the minimum hit ratio of a healthy cache member. * * @see #getMinHitRatio */ - public void setMinHitRatio(double minHitRatio); + void setMinHitRatio(double minHitRatio); /** * Returns the maximum number of entries in the event delivery queue of a healthy cache member. * * @see #DEFAULT_MAX_EVENT_QUEUE_SIZE */ - public long getMaxEventQueueSize(); + long getMaxEventQueueSize(); /** * Sets the maximum number of entries in the event delivery queue of a healthy cache member. * * @see #getMaxEventQueueSize */ - public void setMaxEventQueueSize(long maxEventQueueSize); + void setMaxEventQueueSize(long maxEventQueueSize); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java b/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java index a229281..a0c52de 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java +++ b/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java @@ -28,7 +28,7 @@ public interface CacheServer extends SystemMember, ManagedEntity { * @deprecated as of 5.7 use {@link CacheVm#getVmConfig} instead. */ @Deprecated - public CacheServerConfig getConfig(); + CacheServerConfig getConfig(); /** * Find whether this server is primary for given client (durableClientId) @@ -38,6 +38,6 @@ public interface CacheServer extends SystemMember, ManagedEntity { * * @since GemFire 5.6 */ - public boolean isPrimaryForDurableClient(String durableClientId); + boolean isPrimaryForDurableClient(String durableClientId); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java b/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java index 389d6bc..b069049 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java @@ -29,22 +29,22 @@ public interface CacheServerConfig extends CacheVmConfig { * Returns the <code>cache.xml</code> declarative caching initialization file used to configure * this cache server VM. By default, a cache server VM is started without an XML file. */ - public String getCacheXMLFile(); + String getCacheXMLFile(); /** * Sets the <code>cache.xml</code> declarative caching initialization file used to configure this * cache server VM. */ - public void setCacheXMLFile(String cacheXml); + void setCacheXMLFile(String cacheXml); /** * Returns the location(s) of user classes (such as cache loaders) required by the cache server * VM. */ - public String getClassPath(); + String getClassPath(); /** * Sets the location(s) of user classes (such as cache loaders) required by the cache server VM. */ - public void setClassPath(String classpath); + void setClassPath(String classpath); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java b/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java index 30d8701..23f66dd 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java +++ b/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java @@ -31,5 +31,5 @@ public interface CacheVm extends SystemMember, ManagedEntity { /** * Returns the configuration of this cache vm */ - public CacheVmConfig getVmConfig(); + CacheVmConfig getVmConfig(); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java b/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java index 81f4a38..e59615f 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java @@ -30,22 +30,22 @@ public interface CacheVmConfig extends ManagedEntityConfig { * Returns the <code>cache.xml</code> declarative caching initialization file used to configure * this cache server VM. By default, a cache server VM is started without an XML file. */ - public String getCacheXMLFile(); + String getCacheXMLFile(); /** * Sets the <code>cache.xml</code> declarative caching initialization file used to configure this * cache server VM. */ - public void setCacheXMLFile(String cacheXml); + void setCacheXMLFile(String cacheXml); /** * Returns the location(s) of user classes (such as cache loaders) required by the cache server * VM. */ - public String getClassPath(); + String getClassPath(); /** * Sets the location(s) of user classes (such as cache loaders) required by the cache server VM. */ - public void setClassPath(String classpath); + void setClassPath(String classpath); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java b/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java index 74e1510..4ed4a57 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java +++ b/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java @@ -27,37 +27,37 @@ package org.apache.geode.admin; public interface ConfigurationParameter { /** Gets the identifying name of this configuration parameter. */ - public String getName(); + String getName(); /** Gets the full description of this configuration parameter */ - public String getDescription(); + String getDescription(); /** Gets the current value */ - public Object getValue(); + Object getValue(); /** Gets the current value as a string */ - public String getValueAsString(); + String getValueAsString(); /** Gets the class type of the value */ - public Class getValueType(); + Class getValueType(); /** True if this is modifiable; false if read-only */ - public boolean isModifiable(); + boolean isModifiable(); /** Returns true if this config parameter uses a string array for value. */ - public boolean isArray(); + boolean isArray(); /** Returns true if this config parameter represents an InetAddress value. */ - public boolean isInetAddress(); + boolean isInetAddress(); /** Returns true if this config parameter represents a File value. */ - public boolean isFile(); + boolean isFile(); /** Returns true if this config parameter represents an octal value. */ - public boolean isOctal(); + boolean isOctal(); /** Returns true if this config parameter represents a string value. */ - public boolean isString(); + boolean isString(); /** * Sets a new value for this configuration parameter. @@ -67,6 +67,6 @@ public interface ConfigurationParameter { * @throws UnmodifiableConfigurationException if attempting to set value when isModifiable is * false */ - public void setValue(Object value) throws UnmodifiableConfigurationException; + void setValue(Object value) throws UnmodifiableConfigurationException; } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java b/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java index 940d306..6da5f9f 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java @@ -261,55 +261,55 @@ public interface DistributedSystemConfig extends Cloneable { * * @since GemFire 4.0 */ - public String getEntityConfigXMLFile(); + String getEntityConfigXMLFile(); /** * Sets the name of the XML file that specifies the configuration of managed entities administered * by the <code>DistributedSystem</code>. */ - public void setEntityConfigXMLFile(String xmlFile); + void setEntityConfigXMLFile(String xmlFile); /** Returns the string identity for the system */ - public String getSystemId(); + String getSystemId(); /** Sets the string identity for the system */ - public void setSystemId(String systemId); + void setSystemId(String systemId); /** Returns the optional non-unique name for the system */ - public String getSystemName(); + String getSystemName(); /** Sets the optional non-unique name for the system */ - public void setSystemName(final String name); + void setSystemName(final String name); /** Returns the multicast address for the system */ - public String getMcastAddress(); + String getMcastAddress(); /** Sets the multicast address for the system */ - public void setMcastAddress(String mcastAddress); + void setMcastAddress(String mcastAddress); /** Returns the multicast port for the system */ - public int getMcastPort(); + int getMcastPort(); /** Sets the multicast port for the system */ - public void setMcastPort(int mcastPort); + void setMcastPort(int mcastPort); /** Returns the ack-wait-threshold for the system */ - public int getAckWaitThreshold(); + int getAckWaitThreshold(); /** Sets the ack-wait-threshold for the system */ - public void setAckWaitThreshold(int seconds); + void setAckWaitThreshold(int seconds); /** Returns the ack-severe-alert-threshold for the system */ - public int getAckSevereAlertThreshold(); + int getAckSevereAlertThreshold(); /** Sets the ack-severe-alert-threshold for the system */ - public void setAckSevereAlertThreshold(int seconds); + void setAckSevereAlertThreshold(int seconds); /** Returns a comma-delimited list of locators for the system */ - public String getLocators(); + String getLocators(); /** Sets the comma-delimited list of locators for the system */ - public void setLocators(String locators); + void setLocators(String locators); /** * Returns the membership-port-range property of the Distributed System. This range is given as @@ -317,7 +317,7 @@ public interface DistributedSystemConfig extends Cloneable { * * @since GemFire 6.5 */ - public String getMembershipPortRange(); + String getMembershipPortRange(); /** * Sets the membership-port-range property of the Distributed System. This range is given as two @@ -325,7 +325,7 @@ public interface DistributedSystemConfig extends Cloneable { * * @since GemFire 6.5 */ - public void setMembershipPortRange(String membershipPortRange); + void setMembershipPortRange(String membershipPortRange); /** @@ -333,14 +333,14 @@ public interface DistributedSystemConfig extends Cloneable { * * @since GemFire 6.5 */ - public void setTcpPort(int port); + void setTcpPort(int port); /** * Returns the primary communication port number for the Distributed System. * * @since GemFire 6.5 */ - public int getTcpPort(); + int getTcpPort(); /** @@ -348,166 +348,166 @@ public interface DistributedSystemConfig extends Cloneable { * unicast messaging. This must be consistent across all members of the distributed system. The * default is to enable tcp. */ - public void setDisableTcp(boolean flag); + void setDisableTcp(boolean flag); /** * Returns the disable-tcp property for the system. When tcp is disabled, the cache uses udp for * unicast messaging. This must be consistent across all members of the distributed system. The * default is to enable tcp. */ - public boolean getDisableTcp(); + boolean getDisableTcp(); /** * Turns on network partition detection */ - public void setEnableNetworkPartitionDetection(boolean newValue); + void setEnableNetworkPartitionDetection(boolean newValue); /** * Returns true if network partition detection is enabled. */ - public boolean getEnableNetworkPartitionDetection(); + boolean getEnableNetworkPartitionDetection(); /** * Disables auto reconnect after being forced out of the distributed system */ - public void setDisableAutoReconnect(boolean newValue); + void setDisableAutoReconnect(boolean newValue); /** * Returns true if auto reconnect is disabled */ - public boolean getDisableAutoReconnect(); + boolean getDisableAutoReconnect(); /** * Returns the member-timeout millisecond value used in failure-detection protocols */ - public int getMemberTimeout(); + int getMemberTimeout(); /** * Set the millisecond value of the member-timeout used in failure-detection protocols. This * timeout determines how long a member has to respond to a heartbeat request. The member is given * three chances before being kicked out of the distributed system with a SystemConnectException. */ - public void setMemberTimeout(int value); + void setMemberTimeout(int value); /** * Returns the IP address to which the distributed system's server sockets are bound. * * @since GemFire 4.0 */ - public String getBindAddress(); + String getBindAddress(); /** * Sets the IP address to which the distributed system's server sockets are bound. * * @since GemFire 4.0 */ - public void setBindAddress(String bindAddress); + void setBindAddress(String bindAddress); /** * Returns the IP address to which client/server server sockets are bound */ - public String getServerBindAddress(); + String getServerBindAddress(); /** * Sets the IP address to which a server cache will bind when listening for client cache * connections. */ - public void setServerBindAddress(String bindAddress); + void setServerBindAddress(String bindAddress); /** Returns the remote command setting to use for remote administration */ - public String getRemoteCommand(); + String getRemoteCommand(); /** * Sets the remote command setting to use for remote administration. This attribute may be * modified after this <code>DistributedSystemConfig</code> has been used to create an * <codE>AdminDistributedSystem</code>. */ - public void setRemoteCommand(String command); + void setRemoteCommand(String command); /** Returns the value of the "ssl-enabled" property. */ - public boolean isSSLEnabled(); + boolean isSSLEnabled(); /** Sets the value of the "ssl-enabled" property. */ - public void setSSLEnabled(boolean enabled); + void setSSLEnabled(boolean enabled); /** Returns the value of the "ssl-protocols" property. */ - public String getSSLProtocols(); + String getSSLProtocols(); /** Sets the value of the "ssl-protocols" property. */ - public void setSSLProtocols(String protocols); + void setSSLProtocols(String protocols); /** Returns the value of the "ssl-ciphers" property. */ - public String getSSLCiphers(); + String getSSLCiphers(); /** Sets the value of the "ssl-ciphers" property. */ - public void setSSLCiphers(String ciphers); + void setSSLCiphers(String ciphers); /** Returns the value of the "ssl-require-authentication" property. */ - public boolean isSSLAuthenticationRequired(); + boolean isSSLAuthenticationRequired(); /** Sets the value of the "ssl-require-authentication" property. */ - public void setSSLAuthenticationRequired(boolean authRequired); + void setSSLAuthenticationRequired(boolean authRequired); /** Returns the provider-specific properties for SSL. */ - public Properties getSSLProperties(); + Properties getSSLProperties(); /** Sets the provider-specific properties for SSL. */ - public void setSSLProperties(Properties sslProperties); + void setSSLProperties(Properties sslProperties); /** Adds an SSL property */ - public void addSSLProperty(String key, String value); + void addSSLProperty(String key, String value); /** Removes an SSL property */ - public void removeSSLProperty(String key); + void removeSSLProperty(String key); /** * Returns the name of the log file to which informational messages are written. * * @see org.apache.geode.i18n.LogWriterI18n */ - public String getLogFile(); + String getLogFile(); /** * Sets the name of the log file to which informational messages are written. * * @see org.apache.geode.i18n.LogWriterI18n */ - public void setLogFile(String logFile); + void setLogFile(String logFile); /** * Returns the level at which informational messages are logged. */ - public String getLogLevel(); + String getLogLevel(); /** * Sets the level at which information messages are logged. */ - public void setLogLevel(String logLevel); + void setLogLevel(String logLevel); /** * Returns the log disk space limit in megabytes */ - public int getLogDiskSpaceLimit(); + int getLogDiskSpaceLimit(); /** * Sets the log disk space limit in megabytes */ - public void setLogDiskSpaceLimit(int limit); + void setLogDiskSpaceLimit(int limit); /** * Returns the log file size limit in megabytes */ - public int getLogFileSizeLimit(); + int getLogFileSizeLimit(); /** * Sets the log file size limit in megabytes */ - public void setLogFileSizeLimit(int limit); + void setLogFileSizeLimit(int limit); /** * Returns the refreshInterval in seconds used for auto-polling and updating @@ -516,14 +516,14 @@ public interface DistributedSystemConfig extends Cloneable { * * @since GemFire 6.0 */ - public int getRefreshInterval(); + int getRefreshInterval(); /** * Sets the refreshInterval in seconds * * @since GemFire 6.0 */ - public void setRefreshInterval(int timeInSecs); + void setRefreshInterval(int timeInSecs); /** * Returns an array of configurations for statically known <code>CacheServers</code>. @@ -531,7 +531,7 @@ public interface DistributedSystemConfig extends Cloneable { * @deprecated as of 5.7 use {@link #getCacheVmConfigs} instead. */ @Deprecated - public CacheServerConfig[] getCacheServerConfigs(); + CacheServerConfig[] getCacheServerConfigs(); /** * Creates the configuration for a CacheServer @@ -539,7 +539,7 @@ public interface DistributedSystemConfig extends Cloneable { * @deprecated as of 5.7 use {@link #createCacheVmConfig} instead. */ @Deprecated - public CacheServerConfig createCacheServerConfig(); + CacheServerConfig createCacheServerConfig(); /** * Removes the configuration for a CacheServer @@ -547,51 +547,51 @@ public interface DistributedSystemConfig extends Cloneable { * @deprecated as of 5.7 use {@link #removeCacheVmConfig} instead. */ @Deprecated - public void removeCacheServerConfig(CacheServerConfig managerConfig); + void removeCacheServerConfig(CacheServerConfig managerConfig); /** * Returns an array of configurations for statically known {@link CacheVm}s. * * @since GemFire 5.7 */ - public CacheVmConfig[] getCacheVmConfigs(); + CacheVmConfig[] getCacheVmConfigs(); /** * Creates the configuration for a {@link CacheVm}. * * @since GemFire 5.7 */ - public CacheVmConfig createCacheVmConfig(); + CacheVmConfig createCacheVmConfig(); /** * Removes the configuration for a {@link CacheVm} * * @since GemFire 5.7 */ - public void removeCacheVmConfig(CacheVmConfig existing); + void removeCacheVmConfig(CacheVmConfig existing); /** * Returns configuration information about {@link DistributionLocator}s that are managed by an * <code>AdminDistributedSystem</code>. */ - public DistributionLocatorConfig[] getDistributionLocatorConfigs(); + DistributionLocatorConfig[] getDistributionLocatorConfigs(); /** * Creates a new <code>DistributionLocatorConfig</code> for a distribution locator that is managed * in this distributed system. The default locator config is set to not use multicast */ - public DistributionLocatorConfig createDistributionLocatorConfig(); + DistributionLocatorConfig createDistributionLocatorConfig(); /** * Removes a <code>DistributionLocatorConfig</code> from the distributed system. */ - public void removeDistributionLocatorConfig(DistributionLocatorConfig config); + void removeDistributionLocatorConfig(DistributionLocatorConfig config); /** Registers listener for notification of changes in this config. */ - public void addListener(ConfigListener listener); + void addListener(ConfigListener listener); /** Removes previously registered listener of this config. */ - public void removeListener(ConfigListener listener); + void removeListener(ConfigListener listener); /** * Validates that this distributed system configuration is correct and consistent. @@ -600,7 +600,7 @@ public interface DistributedSystemConfig extends Cloneable { * @throws AdminXmlException If the {@linkplain #getEntityConfigXMLFile entity config XML file} is * not valid */ - public void validate(); + void validate(); /** * Returns a copy of this <code>DistributedSystemConfig</code> object whose configuration can be @@ -609,17 +609,17 @@ public interface DistributedSystemConfig extends Cloneable { * * @since GemFire 4.0 */ - public Object clone() throws CloneNotSupportedException; + Object clone() throws CloneNotSupportedException; ////////////////////// Inner Classes ////////////////////// /** * A listener whose callback methods are invoked when this config changes. */ - public interface ConfigListener extends java.util.EventListener { + interface ConfigListener extends java.util.EventListener { /** Invoked when this configurated is changed. */ - public void configChanged(DistributedSystemConfig config); + void configChanged(DistributedSystemConfig config); } } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java index d7f7751..470073c 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java @@ -52,7 +52,7 @@ public interface DistributedSystemHealthConfig { * The default maximum number of application members that can unexceptedly leave a healthy the * distributed system. */ - public static final long DEFAULT_MAX_DEPARTED_APPLICATIONS = 10; + long DEFAULT_MAX_DEPARTED_APPLICATIONS = 10; /////////////////////// Instance Methods /////////////////////// @@ -62,7 +62,7 @@ public interface DistributedSystemHealthConfig { * * @see #DEFAULT_MAX_DEPARTED_APPLICATIONS */ - public long getMaxDepartedApplications(); + long getMaxDepartedApplications(); /** * Sets the maximum number of application members that can unexceptedly leave a healthy the @@ -70,5 +70,5 @@ public interface DistributedSystemHealthConfig { * * @see #getMaxDepartedApplications */ - public void setMaxDepartedApplications(long maxDepartedApplications); + void setMaxDepartedApplications(long maxDepartedApplications); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java b/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java index cb82679..7e334d2 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java +++ b/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java @@ -32,14 +32,14 @@ public interface DistributionLocator extends ManagedEntity { /** * Returns the identity name for this locator. */ - public String getId(); + String getId(); /** * Returns the configuration object for this distribution locator. * * @since GemFire 4.0 */ - public DistributionLocatorConfig getConfig(); + DistributionLocatorConfig getConfig(); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java b/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java index 6e8794d..9386dea 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java @@ -44,38 +44,38 @@ public interface DistributionLocatorConfig extends ManagedEntityConfig { * Returns the port on which ths distribution locator listens for members to connect. There is no * default locator port, so a non-default port must be specified. */ - public int getPort(); + int getPort(); /** * Sets the port on which the distribution locator listens for members to connect. */ - public void setPort(int port); + void setPort(int port); /** * Returns the address to which the distribution locator's port is (or will be) bound. By default, * the bind address is <code>null</code> meaning that the port will be bound to all network * addresses on the host. */ - public String getBindAddress(); + String getBindAddress(); /** * Sets the address to which the distribution locator's port is (or will be) bound. */ - public void setBindAddress(String bindAddress); + void setBindAddress(String bindAddress); /** * Sets the properties used to configure the locator's DistributedSystem. * * @since GemFire 5.0 */ - public void setDistributedSystemProperties(Properties props); + void setDistributedSystemProperties(Properties props); /** * Retrieves the properties used to configure the locator's DistributedSystem. * * @since GemFire 5.0 */ - public Properties getDistributedSystemProperties(); + Properties getDistributedSystemProperties(); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java b/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java index bb8590a..45b0dd4 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java +++ b/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java @@ -46,7 +46,7 @@ public interface GemFireHealth { * * @see #getHealth */ - public static final Health GOOD_HEALTH = new Health(Health.GOOD_STRING); + Health GOOD_HEALTH = new Health(Health.GOOD_STRING); /** * An indicator that one or more GemFire components is slightly unhealthy. The problem may or may @@ -54,7 +54,7 @@ public interface GemFireHealth { * * @see #getHealth */ - public static final Health OKAY_HEALTH = new Health(Health.OKAY_STRING); + Health OKAY_HEALTH = new Health(Health.OKAY_STRING); /** * An indicator that one or more GemFire components is unhealthy. While it may be possible for the @@ -62,7 +62,7 @@ public interface GemFireHealth { * * @see #getHealth */ - public static final Health POOR_HEALTH = new Health(Health.POOR_STRING); + Health POOR_HEALTH = new Health(Health.POOR_STRING); /////////////////////// Instance Methods /////////////////////// @@ -73,29 +73,29 @@ public interface GemFireHealth { * @see #OKAY_HEALTH * @see #POOR_HEALTH */ - public Health getHealth(); + Health getHealth(); /** * Resets the overall health of the GemFire components to {@link #GOOD_HEALTH}. This operation * should be invoked when the operator has determined that warnings about the components's health * do not need to be regarded. */ - public void resetHealth(); + void resetHealth(); /** * Returns a message that provides a description of the cause of a component's ill health. */ - public String getDiagnosis(); + String getDiagnosis(); /** * Returns the configuration for determining the health of the distributed system itself. */ - public DistributedSystemHealthConfig getDistributedSystemHealthConfig(); + DistributedSystemHealthConfig getDistributedSystemHealthConfig(); /** * Sets the configuration for determining the health of the distributed system itself. */ - public void setDistributedSystemHealthConfig(DistributedSystemHealthConfig config); + void setDistributedSystemHealthConfig(DistributedSystemHealthConfig config); /** * Returns the <code>GemFireHealthConfig</code> for GemFire components whose configurations are @@ -103,7 +103,7 @@ public interface GemFireHealth { * <code>GemFireHealthConfig</code> will not take effect until * {@link #setDefaultGemFireHealthConfig} is invoked. */ - public GemFireHealthConfig getDefaultGemFireHealthConfig(); + GemFireHealthConfig getDefaultGemFireHealthConfig(); /** * Sets the <code>GemFireHealthConfig</code> for GemFire components whose configurations are not @@ -111,7 +111,7 @@ public interface GemFireHealth { * * @throws IllegalArgumentException If <code>config</code> specifies the config for a host */ - public void setDefaultGemFireHealthConfig(GemFireHealthConfig config); + void setDefaultGemFireHealthConfig(GemFireHealthConfig config); /** * Returns the <code>GemFireHealthConfig</code> for GemFire components that reside on a given @@ -121,7 +121,7 @@ public interface GemFireHealth { * @param hostName The {@linkplain java.net.InetAddress#getCanonicalHostName canonical} name of * the host. */ - public GemFireHealthConfig getGemFireHealthConfig(String hostName); + GemFireHealthConfig getGemFireHealthConfig(String hostName); /** * Sets the <code>GemFireHealthConfig</code> for GemFire components that reside on a given host. @@ -136,24 +136,24 @@ public interface GemFireHealth { * no GemFire components running on that host or if <code>config</code> does not configure * host <code>hostName</code>. */ - public void setGemFireHealthConfig(String hostName, GemFireHealthConfig config); + void setGemFireHealthConfig(String hostName, GemFireHealthConfig config); /** * Closes this health monitor and releases all resources associated with it. */ - public void close(); + void close(); /** * Returns whether or not this <code>GemFireHealth</code> is {@linkplain #close closed}. */ - public boolean isClosed(); + boolean isClosed(); ////////////////////// Inner Classes ////////////////////// /** * An enumerated type for the health of GemFire. */ - public static class Health implements java.io.Serializable { + class Health implements java.io.Serializable { private static final long serialVersionUID = 3039539430412151801L; /** The string for good health */ static final String GOOD_STRING = LocalizedStrings.GemFireHealth_GOOD.toLocalizedString(); http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java index b31861f..d61869b 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java @@ -29,7 +29,7 @@ public interface GemFireHealthConfig extends MemberHealthConfig, CacheHealthConf /** * The default number of seconds between assessments of the health of the GemFire components. */ - public static final int DEFAULT_HEALTH_EVALUATION_INTERVAL = 30; + int DEFAULT_HEALTH_EVALUATION_INTERVAL = 30; ////////////////////// Instance Methods ////////////////////// @@ -39,16 +39,16 @@ public interface GemFireHealthConfig extends MemberHealthConfig, CacheHealthConf * * @see GemFireHealth#getGemFireHealthConfig */ - public String getHostName(); + String getHostName(); /** * Sets the number of seconds between assessments of the health of the GemFire components. */ - public void setHealthEvaluationInterval(int interval); + void setHealthEvaluationInterval(int interval); /** * Returns the number of seconds between assessments of the health of the GemFire components. */ - public int getHealthEvaluationInterval(); + int getHealthEvaluationInterval(); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java b/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java index 1eaa892..4960f3d 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java +++ b/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java @@ -37,7 +37,7 @@ public interface ManagedEntity { * * @see #waitToStart */ - public void start() throws AdminException; + void start() throws AdminException; /** * Stops this managed entity. Note that this method may return before the managed entity is @@ -50,7 +50,7 @@ public interface ManagedEntity { * * @see #waitToStop */ - public void stop() throws AdminException; + void stop() throws AdminException; /** * Waits for up to a given number of milliseconds for this managed entity to {@linkplain #start @@ -62,7 +62,7 @@ public interface ManagedEntity { * * @throws InterruptedException If the thread invoking this method is interrupted while waiting. */ - public boolean waitToStart(long timeout) throws InterruptedException; + boolean waitToStart(long timeout) throws InterruptedException; /** * Waits for up to a given number of milliseconds for this managed entity to {@linkplain #stop @@ -74,7 +74,7 @@ public interface ManagedEntity { * * @throws InterruptedException If the thread invoking this method is interrupted while waiting. */ - public boolean waitToStop(long timeout) throws InterruptedException; + boolean waitToStop(long timeout) throws InterruptedException; /** * Returns whether or not this managed entity is running. Note that this operation may attempt to @@ -84,7 +84,7 @@ public interface ManagedEntity { * <code>null</code> or empty (<code>""</code>) * {@linkplain ManagedEntityConfig#getRemoteCommand remote command} has been specified. */ - public boolean isRunning(); + boolean isRunning(); /** * Returns the tail of this manage entity's log file. Note that not all managed entities implement @@ -95,6 +95,6 @@ public interface ManagedEntity { * @throws UnsupportedOperationException If this managed entity does not support retrieving its * log. */ - public String getLog() throws AdminException; + String getLog() throws AdminException; } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java b/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java index 0b7acd7..918aa39 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java @@ -31,32 +31,32 @@ public interface ManagedEntityConfig extends Cloneable { /** * Returns the name of the host on which the managed entity runs or will run. */ - public String getHost(); + String getHost(); /** * Sets the name of the host on which the managed entity will run. */ - public void setHost(String host); + void setHost(String host); /** * Returns the name of the working directory in which the managed entity runs or will run. */ - public String getWorkingDirectory(); + String getWorkingDirectory(); /** * Sets the name of the working directory in which the managed entity will run. */ - public void setWorkingDirectory(String dir); + void setWorkingDirectory(String dir); /** * Returns the name of the GemFire product directory to use when administering the managed entity. */ - public String getProductDirectory(); + String getProductDirectory(); /** * Sets the name of the GemFire product directory to use when administering the managed entity. */ - public void setProductDirectory(String dir); + void setProductDirectory(String dir); /** * Returns the command prefix used to administer a managed entity that is hosted on a remote @@ -64,12 +64,12 @@ public interface ManagedEntityConfig extends Cloneable { * command associated with the {@linkplain AdminDistributedSystem#getRemoteCommand() distributed * system} will be used. */ - public String getRemoteCommand(); + String getRemoteCommand(); /** * Sets the command prefix used to administer a managed entity that is hosted on a remote machine. */ - public void setRemoteCommand(String remoteCommand); + void setRemoteCommand(String remoteCommand); /** * Validates this configuration. @@ -77,12 +77,12 @@ public interface ManagedEntityConfig extends Cloneable { * @throws IllegalStateException If a managed entity cannot be administered using this * configuration */ - public void validate(); + void validate(); /** * Returns a new <code>ManagedEntityConfig</code> with the same configuration as this * <code>ManagedEntityConfig</code>. */ - public Object clone() throws CloneNotSupportedException; + Object clone() throws CloneNotSupportedException; } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java index 63dd605..947e0da 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java @@ -53,25 +53,25 @@ public interface MemberHealthConfig { * The default maximum VM process size (in megabytes) of a health member of the distributed * system. The default value is 1000. */ - public static final long DEFAULT_MAX_VM_PROCESS_SIZE = 1000; + long DEFAULT_MAX_VM_PROCESS_SIZE = 1000; /** * The default maximum number of enqueued incoming or outgoing messages that a healthy member of a * distributed system can have. The default value is 1000. */ - public static final long DEFAULT_MAX_MESSAGE_QUEUE_SIZE = 1000; + long DEFAULT_MAX_MESSAGE_QUEUE_SIZE = 1000; /** * The default maximum number of message reply timeouts that can occur in a given health * monitoring interval. The default value is zero. */ - public static final long DEFAULT_MAX_REPLY_TIMEOUTS = 0; + long DEFAULT_MAX_REPLY_TIMEOUTS = 0; /** * The default maximum multicast retransmission ratio. The default value is 0.20 (twenty percent * of messages retransmitted) */ - public static final double DEFAULT_MAX_RETRANSMISSION_RATIO = 0.20; + double DEFAULT_MAX_RETRANSMISSION_RATIO = 0.20; /////////////////////// Instance Methods /////////////////////// @@ -81,14 +81,14 @@ public interface MemberHealthConfig { * * @see #DEFAULT_MAX_VM_PROCESS_SIZE */ - public long getMaxVMProcessSize(); + long getMaxVMProcessSize(); /** * Sets the maximum VM process size (in megabytes) of a healthy member of the distributed system. * * @see #getMaxVMProcessSize */ - public void setMaxVMProcessSize(long size); + void setMaxVMProcessSize(long size); /** * Returns the maximum number of enqueued incoming or outgoing messages that a healthy member of a @@ -96,7 +96,7 @@ public interface MemberHealthConfig { * * @see #DEFAULT_MAX_MESSAGE_QUEUE_SIZE */ - public long getMaxMessageQueueSize(); + long getMaxMessageQueueSize(); /** * Sets the maximum number of enqueued incoming or outgoing messages that a healthy member of a @@ -104,21 +104,21 @@ public interface MemberHealthConfig { * * @see #getMaxMessageQueueSize */ - public void setMaxMessageQueueSize(long maxMessageQueueSize); + void setMaxMessageQueueSize(long maxMessageQueueSize); /** * Returns the maximum number message replies that can timeout in a healthy member. * * @see #DEFAULT_MAX_REPLY_TIMEOUTS */ - public long getMaxReplyTimeouts(); + long getMaxReplyTimeouts(); /** * Sets the maximum number message replies that can timeout in a healthy member. * * @see #getMaxReplyTimeouts */ - public void setMaxReplyTimeouts(long maxReplyTimeouts); + void setMaxReplyTimeouts(long maxReplyTimeouts); /** * Returns the maximum ratio of multicast retransmissions / total multicast messages. @@ -130,13 +130,13 @@ public interface MemberHealthConfig { * * @see #DEFAULT_MAX_RETRANSMISSION_RATIO */ - public double getMaxRetransmissionRatio(); + double getMaxRetransmissionRatio(); /** * Sets the maximum ratio of multicast retransmissions / total multicast messages. * * @see #getMaxRetransmissionRatio */ - public void setMaxRetransmissionRatio(double ratio); + void setMaxRetransmissionRatio(double ratio); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/Statistic.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/Statistic.java b/geode-core/src/main/java/org/apache/geode/admin/Statistic.java index 428281a..eefd6e8 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/Statistic.java +++ b/geode-core/src/main/java/org/apache/geode/admin/Statistic.java @@ -31,34 +31,34 @@ public interface Statistic extends java.io.Serializable { * * @return the identifying name of this statistic */ - public String getName(); + String getName(); /** * Gets the value of this statistic as a <code>java.lang.Number</code>. * * @return the value of this statistic */ - public Number getValue(); + Number getValue(); /** * Gets the unit of measurement (if any) this statistic represents. * * @return the unit of measurement (if any) this statistic represents */ - public String getUnits(); + String getUnits(); /** * Returns true if this statistic represents a numeric value which always increases. * * @return true if this statistic represents a value which always increases */ - public boolean isCounter(); + boolean isCounter(); /** * Gets the full description of this statistic. * * @return the full description of this statistic */ - public String getDescription(); + String getDescription(); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java b/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java index 1300c6a..e30403c 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java +++ b/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java @@ -31,14 +31,14 @@ public interface StatisticResource { * * @return the identifying name of this resource */ - public String getName(); + String getName(); /** * Gets the full description of this resource. * * @return the full description of this resource */ - public String getDescription(); + String getDescription(); /** * Gets the classification type of this resource. @@ -46,14 +46,14 @@ public interface StatisticResource { * @return the classification type of this resource * @since GemFire 5.0 */ - public String getType(); + String getType(); /** * Returns a display string of the {@link SystemMember} owning this resource. * * @return a display string of the owning {@link SystemMember} */ - public String getOwner(); + String getOwner(); /** * Returns an ID that uniquely identifies the resource within the {@link SystemMember} it belongs @@ -61,14 +61,14 @@ public interface StatisticResource { * * @return unique id within the owning {@link SystemMember} */ - public long getUniqueId(); + long getUniqueId(); /** * Returns a read-only array of every {@link Statistic} in this resource. * * @return read-only array of every {@link Statistic} in this resource */ - public Statistic[] getStatistics(); + Statistic[] getStatistics(); /** * Refreshes the values of every {@link Statistic} in this resource by retrieving them from the @@ -76,7 +76,7 @@ public interface StatisticResource { * * @throws org.apache.geode.admin.AdminException if unable to refresh statistic values */ - public void refresh() throws org.apache.geode.admin.AdminException; + void refresh() throws org.apache.geode.admin.AdminException; } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java index ffd3f06..5de49a5 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java +++ b/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java @@ -30,13 +30,13 @@ import java.net.InetAddress; public interface SystemMember { /** Gets the {@link AdminDistributedSystem} this member belongs to. */ - public AdminDistributedSystem getDistributedSystem(); + AdminDistributedSystem getDistributedSystem(); /** * Gets identifying name of this member. For applications this is the string form of * {@link #getDistributedMember}. For cache servers it is a unique cache server string. */ - public String getId(); + String getId(); /** * Retrieves display friendly name for this member. If this member defined an optional name for @@ -46,19 +46,19 @@ public interface SystemMember { * @see org.apache.geode.distributed.DistributedSystem#connect * @see org.apache.geode.distributed.DistributedSystem#getName */ - public String getName(); + String getName(); /** Gets the type of {@link SystemMemberType} this member is. */ - public SystemMemberType getType(); + SystemMemberType getType(); /** Gets host name of the machine this member resides on. */ - public String getHost(); + String getHost(); /** Gets the host of this member as an <code>java.net.InetAddress<code>. */ - public InetAddress getHostAddress(); + InetAddress getHostAddress(); /** Retrieves the log for this member. */ - public String getLog(); + String getLog(); /** * Returns the GemFire license this member is using. @@ -66,15 +66,15 @@ public interface SystemMember { * @deprecated Removed licensing in 8.0. */ @Deprecated - public java.util.Properties getLicense(); + java.util.Properties getLicense(); /** Returns this member's GemFire version information. */ - public String getVersion(); + String getVersion(); /** * Gets the configuration parameters for this member. */ - public ConfigurationParameter[] getConfiguration(); + ConfigurationParameter[] getConfiguration(); /** * Sets the configuration of this member. The argument is an array of any and all configuration @@ -86,11 +86,11 @@ public interface SystemMember { * @return all configuration parameters including those that were changed * @throws org.apache.geode.admin.AdminException if this fails to make the configuration changes */ - public ConfigurationParameter[] setConfiguration(ConfigurationParameter[] parms) + ConfigurationParameter[] setConfiguration(ConfigurationParameter[] parms) throws org.apache.geode.admin.AdminException; /** Refreshes this member's configuration from the member or it's properties */ - public void refreshConfig() throws org.apache.geode.admin.AdminException; + void refreshConfig() throws org.apache.geode.admin.AdminException; /** * Retrieves this members statistic resources. If the member is not running then an empty array is @@ -100,7 +100,7 @@ public interface SystemMember { * @return array of runtime statistic resources owned by this member * @since GemFire 5.7 */ - public StatisticResource[] getStat(String statisticsTypeName) + StatisticResource[] getStat(String statisticsTypeName) throws org.apache.geode.admin.AdminException; /** @@ -109,7 +109,7 @@ public interface SystemMember { * * @return array of runtime statistic resources owned by this member */ - public StatisticResource[] getStats() throws org.apache.geode.admin.AdminException; + StatisticResource[] getStats() throws org.apache.geode.admin.AdminException; /** * Returns whether or not this system member hosts a GemFire {@link org.apache.geode.cache.Cache @@ -117,13 +117,13 @@ public interface SystemMember { * * @see #getCache */ - public boolean hasCache() throws org.apache.geode.admin.AdminException; + boolean hasCache() throws org.apache.geode.admin.AdminException; /** * Returns an object that provides admin access to this member's cache. If the member currently * has no cache then <code>null</code> is returned. */ - public SystemMemberCache getCache() throws org.apache.geode.admin.AdminException; + SystemMemberCache getCache() throws org.apache.geode.admin.AdminException; /** * Returns the names of the membership roles filled by this member. @@ -131,7 +131,7 @@ public interface SystemMember { * @return array of string membership role names * @since GemFire 5.0 */ - public String[] getRoles(); + String[] getRoles(); /** * Returns the {@link org.apache.geode.distributed.DistributedMember} that represents this system @@ -140,6 +140,6 @@ public interface SystemMember { * @return DistributedMember instance representing this system member * @since GemFire 5.0 */ - public DistributedMember getDistributedMember(); + DistributedMember getDistributedMember(); } http://git-wip-us.apache.org/repos/asf/geode/blob/7c7b577e/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java index 7a1fb1a..451547f 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java +++ b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java @@ -31,37 +31,37 @@ public interface SystemMemberBridgeServer { /** * Returns the port on which this bridge server listens for bridge clients to connect. */ - public int getPort(); + int getPort(); /** * Sets the port on which this bridge server listens for bridge clients to connect. * * @throws AdminException If this bridge server is running */ - public void setPort(int port) throws AdminException; + void setPort(int port) throws AdminException; /** * Starts this bridge server. Once the server is running, its configuration cannot be changed. * * @throws AdminException If an error occurs while starting the bridge server */ - public void start() throws AdminException; + void start() throws AdminException; /** * Returns whether or not this bridge server is running */ - public boolean isRunning(); + boolean isRunning(); /** * Stops this bridge server. Note that the <code>BridgeServer</code> can be reconfigured and * restarted if desired. */ - public void stop() throws AdminException; + void stop() throws AdminException; /** * Updates the information about this bridge server. */ - public void refresh(); + void refresh(); /** * Returns a string representing the ip address or host name that this server will listen on. @@ -69,7 +69,7 @@ public interface SystemMemberBridgeServer { * @return the ip address or host name that this server is to listen on * @since GemFire 5.7 */ - public String getBindAddress(); + String getBindAddress(); /** * Sets the ip address or host name that this server is to listen on for client connections. @@ -89,7 +89,7 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setBindAddress(String address) throws AdminException; + void setBindAddress(String address) throws AdminException; /** * Returns a string representing the ip address or host name that server locators will tell @@ -98,7 +98,7 @@ public interface SystemMemberBridgeServer { * @return the ip address or host name to give to clients so they can connect to this server * @since GemFire 5.7 */ - public String getHostnameForClients(); + String getHostnameForClients(); /** * Sets the ip address or host name that this server is to listen on for client connections. @@ -115,7 +115,7 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setHostnameForClients(String name) throws AdminException; + void setHostnameForClients(String name) throws AdminException; /** * Sets whether or not this bridge server should notify clients based on key subscription. @@ -133,14 +133,14 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setNotifyBySubscription(boolean b) throws AdminException; + void setNotifyBySubscription(boolean b) throws AdminException; /** * Answers whether or not this bridge server should notify clients based on key subscription. * * @since GemFire 5.7 */ - public boolean getNotifyBySubscription(); + boolean getNotifyBySubscription(); /** * Sets the buffer size in bytes of the socket connection for this <code>BridgeServer</code>. The @@ -150,7 +150,7 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setSocketBufferSize(int socketBufferSize) throws AdminException; + void setSocketBufferSize(int socketBufferSize) throws AdminException; /** * Returns the configured buffer size of the socket connection for this <code>BridgeServer</code>. @@ -159,7 +159,7 @@ public interface SystemMemberBridgeServer { * @return the configured buffer size of the socket connection for this <code>BridgeServer</code> * @since GemFire 5.7 */ - public int getSocketBufferSize(); + int getSocketBufferSize(); /** * Sets the maximum amount of time between client pings. This value is used by the @@ -170,7 +170,7 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setMaximumTimeBetweenPings(int maximumTimeBetweenPings) throws AdminException; + void setMaximumTimeBetweenPings(int maximumTimeBetweenPings) throws AdminException; /** * Returns the maximum amount of time between client pings. This value is used by the @@ -180,14 +180,14 @@ public interface SystemMemberBridgeServer { * @return the maximum amount of time between client pings. * @since GemFire 5.7 */ - public int getMaximumTimeBetweenPings(); + int getMaximumTimeBetweenPings(); /** * Returns the maximum allowed client connections * * @since GemFire 5.7 */ - public int getMaxConnections(); + int getMaxConnections(); /** * Sets the maxium number of client connections allowed. When the maximum is reached the server @@ -196,7 +196,7 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setMaxConnections(int maxCons) throws AdminException; + void setMaxConnections(int maxCons) throws AdminException; /** * Returns the maxium number of threads allowed in this server to service client requests. The @@ -204,7 +204,7 @@ public interface SystemMemberBridgeServer { * * @since GemFire 5.7 */ - public int getMaxThreads(); + int getMaxThreads(); /** * Sets the maxium number of threads allowed in this server to service client requests. The @@ -213,14 +213,14 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setMaxThreads(int maxThreads) throws AdminException; + void setMaxThreads(int maxThreads) throws AdminException; /** * Returns the maximum number of messages that can be enqueued in a client-queue. * * @since GemFire 5.7 */ - public int getMaximumMessageCount(); + int getMaximumMessageCount(); /** * Sets maximum number of messages that can be enqueued in a client-queue. @@ -228,14 +228,14 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setMaximumMessageCount(int maxMessageCount) throws AdminException; + void setMaximumMessageCount(int maxMessageCount) throws AdminException; /** * Returns the time (in seconds ) after which a message in the client queue will expire. * * @since GemFire 5.7 */ - public int getMessageTimeToLive(); + int getMessageTimeToLive(); /** * Sets the time (in seconds ) after which a message in the client queue will expire. @@ -243,7 +243,7 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setMessageTimeToLive(int messageTimeToLive) throws AdminException; + void setMessageTimeToLive(int messageTimeToLive) throws AdminException; /** * Sets the list of server groups this bridge server will belong to. By default bridge servers @@ -254,7 +254,7 @@ public interface SystemMemberBridgeServer { * @throws AdminException if this bridge server is running * @since GemFire 5.7 */ - public void setGroups(String[] groups) throws AdminException; + void setGroups(String[] groups) throws AdminException; /** * Returns the list of server groups that this bridge server belongs to. @@ -264,7 +264,7 @@ public interface SystemMemberBridgeServer { * to. * @since GemFire 5.7 */ - public String[] getGroups(); + String[] getGroups(); /** * Get a description of the load probe for this bridge server. {@link ServerLoadProbe} for details @@ -273,7 +273,7 @@ public interface SystemMemberBridgeServer { * @return the load probe used by this bridge server. * @since GemFire 5.7 */ - public String getLoadProbe(); + String getLoadProbe(); /** * Set the load probe for this bridge server. See {@link ServerLoadProbe} for details on how to @@ -286,14 +286,14 @@ public interface SystemMemberBridgeServer { * @throws AdminException if the bridge server is running * @since GemFire 5.7 */ - public void setLoadProbe(ServerLoadProbe loadProbe) throws AdminException; + void setLoadProbe(ServerLoadProbe loadProbe) throws AdminException; /** * Get the frequency in milliseconds to poll the load probe on this bridge server. * * @return the frequency in milliseconds that we will poll the load probe. */ - public long getLoadPollInterval(); + long getLoadPollInterval(); /** * Set the frequency in milliseconds to poll the load probe on this bridge server @@ -302,6 +302,6 @@ public interface SystemMemberBridgeServer { * than 0. * @throws AdminException if the bridge server is running */ - public void setLoadPollInterval(long loadPollInterval) throws AdminException; + void setLoadPollInterval(long loadPollInterval) throws AdminException; }
