http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/Region.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/Region.java b/geode-core/src/main/java/org/apache/geode/cache/Region.java index 61f2c81..2968afd 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/Region.java +++ b/geode-core/src/main/java/org/apache/geode/cache/Region.java @@ -142,10 +142,10 @@ import org.apache.geode.cache.snapshot.RegionSnapshotService; public interface Region<K, V> extends ConcurrentMap<K, V> { /** The region name separator character. */ - public static final char SEPARATOR_CHAR = '/'; + char SEPARATOR_CHAR = '/'; /** The region name separator character, represented as a string for convenience. */ - public static final String SEPARATOR = "/"; + String SEPARATOR = "/"; /** * Returns the name of this region. A region's name can be any non-empty String providing it does @@ -156,7 +156,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return the name of this region */ - public String getName(); + String getName(); /** * Returns the full path of this region starting with a forward slash, followed by the root, @@ -166,7 +166,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return the full path of this region */ - public String getFullPath(); + String getFullPath(); /** * Gets the parent region of this region. If this region is a root region, returns null. @@ -176,7 +176,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return the parent region which contains this region; null, if this region is the root region * @see Region#createSubregion(String, RegionAttributes) createSubregion */ - public <PK, PV> Region<PK, PV> getParentRegion(); + <PK, PV> Region<PK, PV> getParentRegion(); /** * Returns the <code>RegionAttributes</code> for this region. This object is backed by this @@ -191,7 +191,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see AttributesFactory * @see #getAttributesMutator */ - public RegionAttributes<K, V> getAttributes(); + RegionAttributes<K, V> getAttributes(); /** @@ -201,7 +201,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return the <code>AttributesMutator</code> object * @see #getAttributes */ - public AttributesMutator<K, V> getAttributesMutator(); + AttributesMutator<K, V> getAttributesMutator(); /** * Returns the <code>CacheStatistics</code> for this region. @@ -210,7 +210,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws StatisticsDisabledException if statistics have been disabled for this region * @throws UnsupportedOperationException If the region is a partitioned region */ - public CacheStatistics getStatistics() throws StatisticsDisabledException; + CacheStatistics getStatistics() throws StatisticsDisabledException; /** * Invalidates this region. Invalidation cascades to all entries and subregions. After the @@ -225,7 +225,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws TimeoutException if timed out getting distributed lock for <code>Scope.GLOBAL</code> * @see CacheListener#afterRegionInvalidate */ - public void invalidateRegion() throws TimeoutException; + void invalidateRegion() throws TimeoutException; /** * Invalidates this region. The invalidation will cascade to all the subregions and cached @@ -244,7 +244,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws IllegalArgumentException if aCallbackArgument is not serializable * @see CacheListener#afterRegionInvalidate */ - public void invalidateRegion(Object aCallbackArgument) throws TimeoutException; + void invalidateRegion(Object aCallbackArgument) throws TimeoutException; @@ -260,7 +260,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws UnsupportedOperationException If the region is a partitioned region * @see CacheListener#afterRegionInvalidate */ - public void localInvalidateRegion(); + void localInvalidateRegion(); /** * Invalidates this region in the local cache only, and provides a user-defined argument to the @@ -278,7 +278,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheListener#afterRegionInvalidate */ - public void localInvalidateRegion(Object aCallbackArgument); + void localInvalidateRegion(Object aCallbackArgument); /** @@ -297,7 +297,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheListener#afterRegionDestroy * @see CacheWriter#beforeRegionDestroy */ - public void destroyRegion() throws CacheWriterException, TimeoutException; + void destroyRegion() throws CacheWriterException, TimeoutException; /** * Destroys the whole region and provides a user-defined parameter object to any @@ -319,7 +319,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheListener#afterRegionDestroy * @see CacheWriter#beforeRegionDestroy */ - public void destroyRegion(Object aCallbackArgument) throws CacheWriterException, TimeoutException; + void destroyRegion(Object aCallbackArgument) throws CacheWriterException, TimeoutException; /** * Destroys the whole region in the local cache only. No <code>CacheWriter</code> is invoked. @@ -332,7 +332,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @see CacheListener#afterRegionDestroy */ - public void localDestroyRegion(); + void localDestroyRegion(); /** * Destroys the whole region in the local cache only, and provides a user-defined argument to a @@ -348,7 +348,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * call. Can be null. * @see CacheListener#afterRegionDestroy */ - public void localDestroyRegion(Object aCallbackArgument); + void localDestroyRegion(Object aCallbackArgument); /** * Does a localDestroyRegion, but leaves behind the disk files if this is a region with @@ -361,14 +361,14 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see Region#localDestroyRegion() * @see CacheListener#afterRegionDestroy */ - public void close(); + void close(); /** * Obtains the snapshot service to allow the cache data to be imported or exported. * * @return the snapshot service for the region */ - public RegionSnapshotService<K, V> getSnapshotService(); + RegionSnapshotService<K, V> getSnapshotService(); /** * Saves the data in this region in a snapshot file. The data is a "concurrent" snapshot in that @@ -384,7 +384,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @deprecated as of 7.0 use {@link #getSnapshotService()} */ - public void saveSnapshot(OutputStream outputStream) throws IOException; + void saveSnapshot(OutputStream outputStream) throws IOException; /** * Loads data from a file that was previously created with the saveSnapshot method. This method @@ -432,7 +432,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @deprecated as of 7.0 use {@link #getSnapshotService()} */ - public void loadSnapshot(InputStream inputStream) + void loadSnapshot(InputStream inputStream) throws IOException, ClassNotFoundException, CacheWriterException, TimeoutException; /** @@ -447,7 +447,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see Region Region * @see Region#getFullPath */ - public <SK, SV> Region<SK, SV> getSubregion(String path); + <SK, SV> Region<SK, SV> getSubregion(String path); /** @@ -479,7 +479,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @deprecated as of 7.0 use {@link RegionFactory#createSubregion(Region, String)} or * {@link ClientRegionFactory#createSubregion(Region, String)}. */ - public <SK, SV> Region<SK, SV> createSubregion(String subregionName, + <SK, SV> Region<SK, SV> createSubregion(String subregionName, RegionAttributes<SK, SV> aRegionAttributes) throws RegionExistsException, TimeoutException; /** @@ -498,7 +498,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * recursively * @return a Set of subregions */ - public Set<Region<?, ?>> subregions(boolean recursive); + Set<Region<?, ?>> subregions(boolean recursive); /** @@ -508,7 +508,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return the Region.Entry for the specified key or null if not found in this region * @throws NullPointerException if key is null */ - public Entry<K, V> getEntry(Object key); + Entry<K, V> getEntry(Object key); /** * Returns the value associated with the specified key. If the value is not present locally for @@ -557,7 +557,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheWriter#beforeCreate * @see CacheWriter#beforeUpdate */ - public V get(Object key) throws CacheLoaderException, TimeoutException; + V get(Object key) throws CacheLoaderException, TimeoutException; /** * Returns the value associated with the specified key, passing the callback argument to any cache @@ -613,7 +613,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheWriter#beforeCreate * @see CacheWriter#beforeUpdate */ - public V get(Object key, Object aCallbackArgument) throws TimeoutException, CacheLoaderException; + V get(Object key, Object aCallbackArgument) throws TimeoutException, CacheLoaderException; /** * Places a new value into an entry in this region with the specified key. If there is already an @@ -651,7 +651,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheWriter#beforeCreate * @see CacheWriter#beforeUpdate */ - public V put(K key, V value) throws TimeoutException, CacheWriterException; + V put(K key, V value) throws TimeoutException, CacheWriterException; /** @@ -696,8 +696,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheWriter#beforeCreate * @see CacheWriter#beforeUpdate */ - public V put(K key, V value, Object aCallbackArgument) - throws TimeoutException, CacheWriterException; + V put(K key, V value, Object aCallbackArgument) throws TimeoutException, CacheWriterException; /** * Creates a new entry in this region with the specified key and value. @@ -732,8 +731,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheWriter#beforeCreate * @see CacheWriter#beforeUpdate */ - public void create(K key, V value) - throws TimeoutException, EntryExistsException, CacheWriterException; + void create(K key, V value) throws TimeoutException, EntryExistsException, CacheWriterException; /** * Creates a new entry in this region with the specified key and value, providing a user-defined @@ -770,7 +768,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheWriter#beforeCreate * @see CacheWriter#beforeUpdate */ - public void create(K key, V value, Object aCallbackArgument) + void create(K key, V value, Object aCallbackArgument) throws TimeoutException, EntryExistsException, CacheWriterException; /** @@ -790,7 +788,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws EntryNotFoundException if the entry does not exist in this region * @see CacheListener#afterInvalidate */ - public void invalidate(Object key) throws TimeoutException, EntryNotFoundException; + void invalidate(Object key) throws TimeoutException, EntryNotFoundException; /** * Invalidates the entry with the specified key, and provides a user-defined argument to the @@ -813,7 +811,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheListener#afterInvalidate */ - public void invalidate(Object key, Object aCallbackArgument) + void invalidate(Object key, Object aCallbackArgument) throws TimeoutException, EntryNotFoundException; /** @@ -834,7 +832,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws UnsupportedOperationInTransactionException If called in a transactional context * @see CacheListener#afterInvalidate */ - public void localInvalidate(Object key) throws EntryNotFoundException; + void localInvalidate(Object key) throws EntryNotFoundException; /** * Invalidates the value with the specified key in the local cache only, and provides a @@ -856,7 +854,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws UnsupportedOperationInTransactionException If called in a transactional context * @see CacheListener#afterInvalidate */ - public void localInvalidate(Object key, Object aCallbackArgument) throws EntryNotFoundException; + void localInvalidate(Object key, Object aCallbackArgument) throws EntryNotFoundException; /** @@ -885,8 +883,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheListener#afterDestroy * @see CacheWriter#beforeDestroy */ - public V destroy(Object key) - throws TimeoutException, EntryNotFoundException, CacheWriterException; + V destroy(Object key) throws TimeoutException, EntryNotFoundException, CacheWriterException; /** @@ -919,7 +916,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheListener#afterDestroy * @see CacheWriter#beforeDestroy */ - public V destroy(Object key, Object aCallbackArgument) + V destroy(Object key, Object aCallbackArgument) throws TimeoutException, EntryNotFoundException, CacheWriterException; /** @@ -937,7 +934,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws UnsupportedOperationInTransactionException If called in a transactional context * @see CacheListener#afterDestroy */ - public void localDestroy(Object key) throws EntryNotFoundException; + void localDestroy(Object key) throws EntryNotFoundException; /** * Destroys the value with the specified key in the local cache only, and provides a user-defined @@ -957,7 +954,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws UnsupportedOperationInTransactionException If called in a transactional context * @see CacheListener#afterDestroy */ - public void localDestroy(Object key, Object aCallbackArgument) throws EntryNotFoundException; + void localDestroy(Object key, Object aCallbackArgument) throws EntryNotFoundException; /** * Returns a set of keys in the region. @@ -974,7 +971,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return a Set of all the keys */ - public Set<K> keySet(); + Set<K> keySet(); /** * Returns a Collection of values in this region. @@ -994,7 +991,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return a Collection of all the objects cached in this region */ - public Collection<V> values(); + Collection<V> values(); /** * Returns the <code>Set</code> of <code>Region.Entry</code> objects in this region. If the @@ -1016,7 +1013,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return a Set of all the cached objects * @see Region.Entry */ - public Set<Region.Entry<?, ?>> entrySet(boolean recursive); + Set<Region.Entry<?, ?>> entrySet(boolean recursive); /** * Returns the <code>Cache</code> associated with this region. @@ -1027,7 +1024,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @deprecated as of 6.5 use {@link #getRegionService()} instead. */ @Deprecated - public Cache getCache(); + Cache getCache(); /** * Returns the <code>cache</code> associated with this region. @@ -1037,7 +1034,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return the cache * @since GemFire 6.5 */ - public RegionService getRegionService(); + RegionService getRegionService(); /** * Returns the application-defined object associated with this region. GemFire does not use this @@ -1045,7 +1042,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return the user attribute object or null if it has not been set */ - public Object getUserAttribute(); + Object getUserAttribute(); /** * Sets the application-defined object associated with this region. GemFire does not use this @@ -1053,7 +1050,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @param value the application-defined object */ - public void setUserAttribute(Object value); + void setUserAttribute(Object value); /** * Returns whether this region has been destroyed. @@ -1063,7 +1060,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return true if this region has been destroyed */ - public boolean isDestroyed(); + boolean isDestroyed(); /** * Returns whether there is a valid (non-null) value present for the specified key. This method is @@ -1077,7 +1074,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @param key the key to check for a valid value * @return true if there is an entry in this region for the specified key and it has a valid value */ - public boolean containsValueForKey(Object key); + boolean containsValueForKey(Object key); /** * Returns whether the specified key currently exists in this region. This method is equivalent to @@ -1086,7 +1083,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @param key the key to check for an existing entry * @return true if there is an entry in this region for the specified key */ - public boolean containsKey(Object key); + boolean containsKey(Object key); /** @@ -1113,7 +1110,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws IllegalStateException if the scope of this region is not global * @throws UnsupportedOperationException If the region is a partitioned region */ - public Lock getRegionDistributedLock() throws IllegalStateException; + Lock getRegionDistributedLock() throws IllegalStateException; /** * For {@link Scope#GLOBAL} regions, gets a <em>distributed</em> lock on the entry with the @@ -1153,7 +1150,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @throws NullPointerException if key is null * @throws UnsupportedOperationException If the region is a partitioned region */ - public Lock getDistributedLock(Object key) throws IllegalStateException; + Lock getDistributedLock(Object key) throws IllegalStateException; /** * Initiates a flush to asynchronously write unwritten region entries to disk. @@ -1166,7 +1163,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @deprecated use {@link DiskStore#flush} instead. */ @Deprecated - public void writeToDisk(); + void writeToDisk(); /** * Determines whether there is a value in this <code>Region</code> that matches the given @@ -1186,8 +1183,8 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.0 */ - public boolean existsValue(String queryPredicate) throws FunctionDomainException, - TypeMismatchException, NameResolutionException, QueryInvocationTargetException; + boolean existsValue(String queryPredicate) throws FunctionDomainException, TypeMismatchException, + NameResolutionException, QueryInvocationTargetException; /** * Filters the values of this region using the <code>queryPredicate</code>. The queryPredicate @@ -1211,7 +1208,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.0 */ - public <E> SelectResults<E> query(String queryPredicate) throws FunctionDomainException, + <E> SelectResults<E> query(String queryPredicate) throws FunctionDomainException, TypeMismatchException, NameResolutionException, QueryInvocationTargetException; /** @@ -1232,8 +1229,8 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see QueryService * @since GemFire 4.0 */ - public Object selectValue(String queryPredicate) throws FunctionDomainException, - TypeMismatchException, NameResolutionException, QueryInvocationTargetException; + Object selectValue(String queryPredicate) throws FunctionDomainException, TypeMismatchException, + NameResolutionException, QueryInvocationTargetException; /** * Asks the region to start writing to a new oplog (if persistence/overflow is turned on). The old @@ -1249,7 +1246,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @deprecated use {@link DiskStore#forceRoll} instead. */ @Deprecated - public void forceRolling(); + void forceRolling(); /** * Specifies this member to become the grantor for this region's lock service. The grantor will be @@ -1275,7 +1272,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.0 */ - public void becomeLockGrantor(); + void becomeLockGrantor(); /** * Removes all local entries from this region. This is not a distributed operation. This operation @@ -1287,7 +1284,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheListener#afterRegionClear * */ - public void localClear(); + void localClear(); ////// Map API's //// /** @@ -1301,7 +1298,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see CacheWriter#beforeRegionClear * @throws UnsupportedOperationException If the region is a partitioned region */ - public void clear(); + void clear(); /** * Returns true if this region maps one or more keys to the specified value. More formally, @@ -1312,7 +1309,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @since GemFire 5.0 * @see java.util.Map#containsValue(Object) */ - public boolean containsValue(Object value); + boolean containsValue(Object value); /** * Returns the <code>Set</code> of <code>Region.Entry</code> objects in this region. @@ -1335,7 +1332,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @since GemFire 5.0 * @see java.util.Map#entrySet() */ - public Set<Map.Entry<K, V>> entrySet(); // @todo darrel: should be Region.Entry + Set<Map.Entry<K, V>> entrySet(); // @todo darrel: should be Region.Entry /** * Returns true if this region contains no entries. @@ -1344,7 +1341,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see java.util.Map#isEmpty() * @return true if this region contains no entries. */ - public boolean isEmpty(); + boolean isEmpty(); /** * Copies all of the entries from the specified map to this region. The effect of this call is @@ -1357,7 +1354,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see java.util.Map#putAll(Map map) * @throws LowMemoryException if a low memory condition is detected. */ - public void putAll(Map<? extends K, ? extends V> map); + void putAll(Map<? extends K, ? extends V> map); /** * Copies all of the entries from the specified map to this region. The effect of this call is @@ -1372,7 +1369,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see java.util.Map#putAll(Map map) * @throws LowMemoryException if a low memory condition is detected. */ - public void putAll(Map<? extends K, ? extends V> map, Object aCallbackArgument); + void putAll(Map<? extends K, ? extends V> map, Object aCallbackArgument); /** * Removes all of the entries for the specified keys from this region. The effect of this call is @@ -1385,7 +1382,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @since GemFire 8.1 * @see Region#destroy(Object) */ - public void removeAll(Collection<? extends K> keys); + void removeAll(Collection<? extends K> keys); /** * Removes all of the entries for the specified keys from this region. The effect of this call is @@ -1400,7 +1397,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @since GemFire 8.1 * @see Region#destroy(Object, Object) */ - public void removeAll(Collection<? extends K> keys, Object aCallbackArgument); + void removeAll(Collection<? extends K> keys, Object aCallbackArgument); /** * Gets values for all the keys in the input Collection. If a given key does not exist in the @@ -1415,7 +1412,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 5.7 */ - public Map<K, V> getAll(Collection<?> keys); + Map<K, V> getAll(Collection<?> keys); /** * Gets and returns values for all the keys in the input Collection. If a given key does not exist @@ -1434,7 +1431,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 8.1 */ - public <T extends K> Map<T, V> getAll(Collection<T> keys, Object aCallbackArgument); + <T extends K> Map<T, V> getAll(Collection<T> keys, Object aCallbackArgument); /** @@ -1467,7 +1464,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 5.0 */ - public V remove(Object key); + V remove(Object key); /** * Returns the number of entries present in this region. @@ -1482,7 +1479,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @see java.util.Map#size() * @return the number of entries present in this region */ - public int size(); + int size(); /** * @@ -1495,7 +1492,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return <tt>true</tt> if the specified object is equal to this region. * @see Object#equals */ - public boolean equals(Object other); + boolean equals(Object other); /** * Returns the hash code value for this region. The hash code of a region is based on identity and @@ -1504,7 +1501,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return the hash code value for this region. * @see Object#hashCode() */ - public int hashCode(); + int hashCode(); /** * Sends a request to the CacheServer to register interest in a key for this client. Updates to @@ -1545,7 +1542,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * enabled. * @throws UnsupportedOperationException if the region is a replicate with distributed scope. */ - public void registerInterest(K key); + void registerInterest(K key); /** * Sends a request to the CacheServer to register interest in a key for this client. Updates to @@ -1590,7 +1587,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.2.3 */ - public void registerInterest(K key, InterestResultPolicy policy); + void registerInterest(K key, InterestResultPolicy policy); /** * Sends a request to the CacheServer to register interest in a regular expression pattern for @@ -1629,7 +1626,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.2.3 */ - public void registerInterestRegex(String regex); + void registerInterestRegex(String regex); /** * Sends a request to the CacheServer to register interest in a regular expression pattern for @@ -1669,7 +1666,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.2.3 */ - public void registerInterestRegex(String regex, InterestResultPolicy policy); + void registerInterestRegex(String regex, InterestResultPolicy policy); /** * Sends a request to the CacheServer to unregister interest in a key for this client. Updates to @@ -1682,7 +1679,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.2 */ - public void unregisterInterest(K key); + void unregisterInterest(K key); /** * Sends a request to the CacheServer to unregister interest in a regular expression pattern for @@ -1695,7 +1692,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.2.3 */ - public void unregisterInterestRegex(String regex); + void unregisterInterestRegex(String regex); /** * Returns the list of keys on which this client is interested and will be notified of changes. @@ -1706,7 +1703,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.2 */ - public List<K> getInterestList(); + List<K> getInterestList(); /** @@ -1750,7 +1747,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * enabled. * @throws UnsupportedOperationException if the region is a replicate with distributed scope. */ - public void registerInterest(K key, boolean isDurable); + void registerInterest(K key, boolean isDurable); /** * Sends a request to the CacheServer to register interest in a key for this client. Updates to @@ -1796,7 +1793,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * enabled. * @throws UnsupportedOperationException if the region is a replicate with distributed scope. */ - public void registerInterest(K key, boolean isDurable, boolean receiveValues); + void registerInterest(K key, boolean isDurable, boolean receiveValues); /** * Sends a request to the CacheServer to register interest in a key for this client. Updates to @@ -1844,7 +1841,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 6.0.3 */ - public void registerInterest(K key, InterestResultPolicy policy, boolean isDurable, + void registerInterest(K key, InterestResultPolicy policy, boolean isDurable, boolean receiveValues); /** @@ -1891,7 +1888,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 5.5 */ - public void registerInterest(K key, InterestResultPolicy policy, boolean isDurable); + void registerInterest(K key, InterestResultPolicy policy, boolean isDurable); /** * Sends a request to the CacheServer to register interest in a regular expression pattern for @@ -1931,7 +1928,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 5.5 */ - public void registerInterestRegex(String regex, boolean isDurable); + void registerInterestRegex(String regex, boolean isDurable); /** * Sends a request to the CacheServer to register interest in a regular expression pattern for @@ -1973,7 +1970,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 6.0.3 */ - public void registerInterestRegex(String regex, boolean isDurable, boolean receiveValues); + void registerInterestRegex(String regex, boolean isDurable, boolean receiveValues); /** * Sends a request to the CacheServer to register interest in a regular expression pattern for @@ -2014,7 +2011,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 5.5 */ - public void registerInterestRegex(String regex, InterestResultPolicy policy, boolean isDurable); + void registerInterestRegex(String regex, InterestResultPolicy policy, boolean isDurable); /** * Sends a request to the CacheServer to register interest in a regular expression pattern for @@ -2057,7 +2054,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 6.0.3 */ - public void registerInterestRegex(String regex, InterestResultPolicy policy, boolean isDurable, + void registerInterestRegex(String regex, InterestResultPolicy policy, boolean isDurable, boolean receiveValues); /** @@ -2070,7 +2067,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 4.2.3 */ - public List<String> getInterestListRegex(); + List<String> getInterestListRegex(); /** * Returns a set of keys in the region on the server. @@ -2080,7 +2077,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 5.0.2 */ - public Set<K> keySetOnServer(); + Set<K> keySetOnServer(); /** * Returns whether the specified key currently exists in this region on the server. @@ -2091,7 +2088,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @since GemFire 5.0.2 */ - public boolean containsKeyOnServer(Object key); + boolean containsKeyOnServer(Object key); /** * Returns the number of entries present in this region on the server. Entries stored in this @@ -2309,14 +2306,14 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * Cache is closed at the time of invocation, or an <code>EntryDestroyedException</code> if the * entry has been destroyed. */ - public interface Entry<K, V> extends Map.Entry<K, V> { + interface Entry<K, V> extends Map.Entry<K, V> { /** * Returns the key for this entry. * * @return the key for this entry */ - public K getKey(); + K getKey(); /** * Returns the value of this entry in the local cache. Does not invoke a @@ -2324,14 +2321,14 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return the value or <code>null</code> if this entry is invalid */ - public V getValue(); + V getValue(); /** * Returns the region that contains this entry. * * @return the Region that contains this entry */ - public Region<K, V> getRegion(); + Region<K, V> getRegion(); /** * This method checks to see if the entry is in the in-process cache, or is in another process. @@ -2341,7 +2338,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * corresponding key. To see an updated snapshot of a non-local Entry, you must fetch the entry * from the Region again. */ - public boolean isLocal(); + boolean isLocal(); /** * Returns the statistics for this entry. @@ -2349,14 +2346,14 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @return the CacheStatistics for this entry * @throws StatisticsDisabledException if statistics have been disabled for this region */ - public CacheStatistics getStatistics(); + CacheStatistics getStatistics(); /** * Returns the user attribute for this entry in the local cache. * * @return the user attribute for this entry */ - public Object getUserAttribute(); + Object getUserAttribute(); /** * Sets the user attribute for this entry. Does not distribute the user attribute to other @@ -2365,7 +2362,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @param userAttribute the user attribute for this entry * @return the previous user attribute or null no user attributes has been set for this entry */ - public Object setUserAttribute(Object userAttribute); + Object setUserAttribute(Object userAttribute); /** * Returns whether this entry has been destroyed. @@ -2374,7 +2371,7 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * * @return true if this entry has been destroyed */ - public boolean isDestroyed(); + boolean isDestroyed(); /** * Sets the value of this entry. It has similar to calling a put on the key of this Entry @@ -2392,6 +2389,6 @@ public interface Region<K, V> extends ConcurrentMap<K, V> { * @since GemFire 5.0 * @see Region#put(Object, Object) */ - public V setValue(V value); + V setValue(V value); } }
http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/RegionAttributes.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/RegionAttributes.java b/geode-core/src/main/java/org/apache/geode/cache/RegionAttributes.java index 06695b3..2b93a2a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/RegionAttributes.java +++ b/geode-core/src/main/java/org/apache/geode/cache/RegionAttributes.java @@ -47,21 +47,21 @@ public interface RegionAttributes<K, V> { * * @return the cache loader */ - public CacheLoader<K, V> getCacheLoader(); + CacheLoader<K, V> getCacheLoader(); /** * Returns the cache writer associated with this region. * * @return the cache writer */ - public CacheWriter<K, V> getCacheWriter(); + CacheWriter<K, V> getCacheWriter(); /** * Returns the class that the keys in this region are constrained to. * * @return the <code>Class</code> the keys must be an <code>instanceof</code> */ - public Class<K> getKeyConstraint(); + Class<K> getKeyConstraint(); /** * Returns the class that the values in this region are constrained to. @@ -69,7 +69,7 @@ public interface RegionAttributes<K, V> { * @return the <code>Class</code> the values must be an <code>instanceof</code> */ - public Class<V> getValueConstraint(); + Class<V> getValueConstraint(); /** @@ -78,7 +78,7 @@ public interface RegionAttributes<K, V> { * * @return the timeToLive expiration attributes for this region */ - public ExpirationAttributes getRegionTimeToLive(); + ExpirationAttributes getRegionTimeToLive(); /** * Gets the idleTimeout expiration attributes for the region as a whole. Default is 0 which @@ -87,7 +87,7 @@ public interface RegionAttributes<K, V> { * * @return the IdleTimeout expiration attributes for this region */ - public ExpirationAttributes getRegionIdleTimeout(); + ExpirationAttributes getRegionIdleTimeout(); /** * Gets the <code>timeToLive</code> expiration attributes for entries in this region. Default is 0 @@ -95,7 +95,7 @@ public interface RegionAttributes<K, V> { * * @return the timeToLive expiration attributes for entries in this region */ - public ExpirationAttributes getEntryTimeToLive(); + ExpirationAttributes getEntryTimeToLive(); /** * Gets the <code>idleTimeout</code> expiration attributes for entries in this region. Default is @@ -104,7 +104,7 @@ public interface RegionAttributes<K, V> { * * @return the idleTimeout expiration attributes for entries in this region */ - public ExpirationAttributes getEntryIdleTimeout(); + ExpirationAttributes getEntryIdleTimeout(); /** * Gets the <code>entryTimeToLive</code> <code>CustomExpiry</code>, if any for entries in this @@ -112,21 +112,21 @@ public interface RegionAttributes<K, V> { * * @return the entryTimeToLive CustomExpiry for entries in this region */ - public CustomExpiry<K, V> getCustomEntryTimeToLive(); + CustomExpiry<K, V> getCustomEntryTimeToLive(); /** * Gets the <code>idleTimeout</code> <code>CustomExpiry</code>, if any for entries in this region * * @return the idleTimeout CustomExpiry for entries in this region */ - public CustomExpiry<K, V> getCustomEntryIdleTimeout(); + CustomExpiry<K, V> getCustomEntryIdleTimeout(); /** * Gets the flag telling a region to ignore JTA transactions. Default value is set to false. * * @since GemFire 5.0 */ - public boolean getIgnoreJTA(); + boolean getIgnoreJTA(); /** * Returns the type of mirroring for this region. @@ -135,7 +135,7 @@ public interface RegionAttributes<K, V> { * @deprecated as of GemFire 5.0, use {@link #getDataPolicy} instead. */ @Deprecated - public MirrorType getMirrorType(); + MirrorType getMirrorType(); /** @@ -145,7 +145,7 @@ public interface RegionAttributes<K, V> { * @return the region's <code>DataPolicy</code> * @since GemFire 5.0 */ - public DataPolicy getDataPolicy(); + DataPolicy getDataPolicy(); /** * Returns the scope of the region. Default scope is DISTRIBUTED_NO_ACK. Please refer the gemfire @@ -153,7 +153,7 @@ public interface RegionAttributes<K, V> { * * @return the region's <code>Scope</code> */ - public Scope getScope(); + Scope getScope(); /** @@ -162,7 +162,7 @@ public interface RegionAttributes<K, V> { * * @return the region's EvictionAttributes */ - public EvictionAttributes getEvictionAttributes(); + EvictionAttributes getEvictionAttributes(); /** * Returns the cache listener for the region. @@ -172,7 +172,7 @@ public interface RegionAttributes<K, V> { * @deprecated as of GemFire 5.0, use {@link #getCacheListeners} instead */ @Deprecated - public CacheListener<K, V> getCacheListener(); + CacheListener<K, V> getCacheListener(); /** * Returns an array of all the cache listeners on this attributes. Modifications to the returned @@ -181,7 +181,7 @@ public interface RegionAttributes<K, V> { * @return the region's <code>CacheListener</code>s; an empty array if no listeners * @since GemFire 5.0 */ - public CacheListener<K, V>[] getCacheListeners(); + CacheListener<K, V>[] getCacheListeners(); // MAP ATTRIBUTES @@ -192,7 +192,7 @@ public interface RegionAttributes<K, V> { * @return the initial capacity of the entries map * @see java.util.HashMap */ - public int getInitialCapacity(); + int getInitialCapacity(); /** * Returns the load factor of the entries map. Default is 0.75. @@ -200,7 +200,7 @@ public interface RegionAttributes<K, V> { * @return the load factor of the entries map * @see java.util.HashMap */ - public float getLoadFactor(); + float getLoadFactor(); /** * Returns true if this member is configured to be lock grantor for the region. Result will always @@ -214,7 +214,7 @@ public interface RegionAttributes<K, V> { * @see AttributesFactory * @see Region#becomeLockGrantor */ - public boolean isLockGrantor(); + boolean isLockGrantor(); /** * Returns true if multicast communications are enabled for this region. Multicast must also be @@ -224,7 +224,7 @@ public interface RegionAttributes<K, V> { * @return true if this region is configured to allow use of multicast for distributed messaging * @see AttributesFactory#setMulticastEnabled */ - public boolean getMulticastEnabled(); + boolean getMulticastEnabled(); /** * Returns the concurrencyLevel of the entries map. Default is 16. @@ -232,7 +232,7 @@ public interface RegionAttributes<K, V> { * @return the concurrencyLevel * @see AttributesFactory */ - public int getConcurrencyLevel(); + int getConcurrencyLevel(); /** * Returns whether or not a persistent backup should be made of the region (as opposed to just @@ -242,7 +242,7 @@ public interface RegionAttributes<K, V> { * @deprecated as of GemFire 5.0, use {@link DataPolicy#PERSISTENT_REPLICATE} instead */ @Deprecated - public boolean getPersistBackup(); + boolean getPersistBackup(); /** * Returns the <code>DiskWriteAttributes</code> that configure how the region is written to disk. @@ -251,7 +251,7 @@ public interface RegionAttributes<K, V> { * @deprecated as of 6.5 use {@link #getDiskStoreName} instead. */ @Deprecated - public DiskWriteAttributes getDiskWriteAttributes(); + DiskWriteAttributes getDiskWriteAttributes(); /** * Returns the directories to which the region's data are written. If multiple directories are @@ -261,7 +261,7 @@ public interface RegionAttributes<K, V> { * @deprecated as of 6.5 use {@link DiskStore#getDiskDirs} instead. */ @Deprecated - public File[] getDiskDirs(); + File[] getDiskDirs(); /** * Returns the value of <code>IndexMaintenanceSynchronous</code> which specifies whether the @@ -270,14 +270,14 @@ public interface RegionAttributes<K, V> { * * @since GemFire 4.0 */ - public boolean getIndexMaintenanceSynchronous(); + boolean getIndexMaintenanceSynchronous(); /** * Returns the <code>PartitionAttributes</code> that configure how the region is partitioned. * * @since GemFire 5.0 */ - public PartitionAttributes getPartitionAttributes(); + PartitionAttributes getPartitionAttributes(); /** * Returns the <code>MembershipAttributes</code> that configure required roles for reliable access @@ -285,7 +285,7 @@ public interface RegionAttributes<K, V> { * * @deprecated this API is scheduled to be removed */ - public MembershipAttributes getMembershipAttributes(); + MembershipAttributes getMembershipAttributes(); /** * Returns the <code>SubscriptionAttributes</code> that configure how this region behaves as a @@ -293,7 +293,7 @@ public interface RegionAttributes<K, V> { * * @since GemFire 5.0 */ - public SubscriptionAttributes getSubscriptionAttributes(); + SubscriptionAttributes getSubscriptionAttributes(); // STATISTICS @@ -302,7 +302,7 @@ public interface RegionAttributes<K, V> { * * @return true if statistics are enabled */ - public boolean getStatisticsEnabled(); + boolean getStatisticsEnabled(); /** * Returns whether or not acks are sent after an update is processed. @@ -314,7 +314,7 @@ public interface RegionAttributes<K, V> { * @deprecated Setting early ack no longer has any effect. */ @Deprecated - public boolean getEarlyAck(); + boolean getEarlyAck(); /** * Returns whether or not this region is a publisher. Publishers are regions on which distributed @@ -325,7 +325,7 @@ public interface RegionAttributes<K, V> { * @since GemFire 4.2.3 * @deprecated as of 6.5 */ - public boolean getPublisher(); + boolean getPublisher(); /** * Returns whether or not conflation is enabled for sending messages from a cache server to its @@ -340,7 +340,7 @@ public interface RegionAttributes<K, V> { * @since GemFire 4.2 */ @Deprecated - public boolean getEnableConflation(); + boolean getEnableConflation(); /** * Returns whether or not conflation is enabled for sending messages from a cache server to its @@ -355,7 +355,7 @@ public interface RegionAttributes<K, V> { * @deprecated as of GemFire 5.0, use {@link #getEnableSubscriptionConflation} instead */ @Deprecated - public boolean getEnableBridgeConflation(); + boolean getEnableBridgeConflation(); /** * Returns whether or not conflation is enabled for sending messages from a cache server to its @@ -370,7 +370,7 @@ public interface RegionAttributes<K, V> { * * @since GemFire 5.7 */ - public boolean getEnableSubscriptionConflation(); + boolean getEnableSubscriptionConflation(); /** * Returns whether or not async conflation is enabled for sending messages to async peers. @@ -381,7 +381,7 @@ public interface RegionAttributes<K, V> { * * @since GemFire 4.2.3 */ - public boolean getEnableAsyncConflation(); + boolean getEnableAsyncConflation(); /** * Returns the sizes of the disk directories in megabytes @@ -389,7 +389,7 @@ public interface RegionAttributes<K, V> { * @return int[] sizes of the disk directories * @deprecated as of 6.5 use {@link DiskStore#getDiskDirSizes} instead. */ - public int[] getDiskDirSizes(); + int[] getDiskDirSizes(); /** @@ -400,7 +400,7 @@ public interface RegionAttributes<K, V> { * communication; <code>null</code> is returned if the region communicates with peers. * @since GemFire 5.7 */ - public String getPoolName(); + String getPoolName(); /** * Returns whether or not cloning is enabled on region. Default is false. @@ -409,7 +409,7 @@ public interface RegionAttributes<K, V> { * * @since GemFire 6.1 */ - public boolean getCloningEnabled(); + boolean getCloningEnabled(); /** * Returns the name of the {@link DiskStore} that this region belongs to, if any. Returns @@ -419,7 +419,7 @@ public interface RegionAttributes<K, V> { * region belongs to default {@link DiskStore}. * @since GemFire 6.5 */ - public String getDiskStoreName(); + String getDiskStoreName(); /** * Returns true if configured synchronous disk writes. Default is set to true. @@ -427,17 +427,17 @@ public interface RegionAttributes<K, V> { * @return Returns true if writes to disk are synchronous and false otherwise * @since GemFire 6.5 */ - public boolean isDiskSynchronous(); + boolean isDiskSynchronous(); /** * Returns a set of gatewaysenderIds */ - public Set<String> getGatewaySenderIds(); + Set<String> getGatewaySenderIds(); /** * Returns a set of AsyncEventQueueIds added to the region */ - public Set<String> getAsyncEventQueueIds(); + Set<String> getAsyncEventQueueIds(); /** * Returns true if concurrent update checks are turned on for this region. @@ -451,7 +451,7 @@ public interface RegionAttributes<K, V> { * @since GemFire 7.0 * @return true if concurrent update checks are turned on */ - public boolean getConcurrencyChecksEnabled(); + boolean getConcurrencyChecksEnabled(); /** * Returns the compressor used by this region's entry values. @@ -459,7 +459,7 @@ public interface RegionAttributes<K, V> { * @since GemFire 8.0 * @return null if the region does not have compression enabled. */ - public Compressor getCompressor(); + Compressor getCompressor(); /** * Returns whether or not this region uses off-heap memory. @@ -468,7 +468,7 @@ public interface RegionAttributes<K, V> { * disabled (default). * @since Geode 1.0 */ - public boolean getOffHeap(); + boolean getOffHeap(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/RegionEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/RegionEvent.java b/geode-core/src/main/java/org/apache/geode/cache/RegionEvent.java index 7892372..4eed45f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/RegionEvent.java +++ b/geode-core/src/main/java/org/apache/geode/cache/RegionEvent.java @@ -33,6 +33,6 @@ public interface RegionEvent<K, V> extends CacheEvent<K, V> { * Return true if this region was destroyed but is being reinitialized, for example if a snapshot * was just loaded. Can only return true for an event related to region destruction. */ - public boolean isReinitializing(); + boolean isReinitializing(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/RegionMembershipListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/RegionMembershipListener.java b/geode-core/src/main/java/org/apache/geode/cache/RegionMembershipListener.java index 8c31b31..fd08771 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/RegionMembershipListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/RegionMembershipListener.java @@ -46,14 +46,14 @@ public interface RegionMembershipListener<K, V> extends CacheListener<K, V> { * @param initialMembers an array of the other members that have this region at the time this * listener is added. */ - public void initialMembers(Region<K, V> region, DistributedMember[] initialMembers); + void initialMembers(Region<K, V> region, DistributedMember[] initialMembers); /** * Invoked when another member has created the distributed region this listener is on. * * @param event the event from the member whose region was created. */ - public void afterRemoteRegionCreate(RegionEvent<K, V> event); + void afterRemoteRegionCreate(RegionEvent<K, V> event); /** * Invoked when another member's distributed region is no longer available to this cache due to @@ -68,7 +68,7 @@ public interface RegionMembershipListener<K, V> extends CacheListener<K, V> { * * @param event the event from the member whose region is no longer available. */ - public void afterRemoteRegionDeparture(RegionEvent<K, V> event); + void afterRemoteRegionDeparture(RegionEvent<K, V> event); /** * Invoked when another member's distributed region is no longer available to this cache because @@ -77,5 +77,5 @@ public interface RegionMembershipListener<K, V> extends CacheListener<K, V> { * * @param event the event from the member whose region is no longer available. */ - public void afterRemoteRegionCrash(RegionEvent<K, V> event); + void afterRemoteRegionCrash(RegionEvent<K, V> event); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/RegionRoleListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/RegionRoleListener.java b/geode-core/src/main/java/org/apache/geode/cache/RegionRoleListener.java index 0a666cc..84dca23 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/RegionRoleListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/RegionRoleListener.java @@ -35,14 +35,14 @@ public interface RegionRoleListener<K, V> extends CacheListener<K, V> { * * @param event describes the member that fills the required role. */ - public void afterRoleGain(RoleEvent<K, V> event); + void afterRoleGain(RoleEvent<K, V> event); /** * Invoked when a required role is no longer available in the distributed system. * * @param event describes the member that last filled the required role. */ - public void afterRoleLoss(RoleEvent<K, V> event); + void afterRoleLoss(RoleEvent<K, V> event); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/RegionService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/RegionService.java b/geode-core/src/main/java/org/apache/geode/cache/RegionService.java index 5583260..18acfd7 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/RegionService.java +++ b/geode-core/src/main/java/org/apache/geode/cache/RegionService.java @@ -49,7 +49,7 @@ public interface RegionService extends AutoCloseable { * * @return the service's cancellation object */ - public CancelCriterion getCancelCriterion(); + CancelCriterion getCancelCriterion(); /** * Return the existing region (or subregion) with the specified path. Whether or not the path @@ -59,7 +59,7 @@ public interface RegionService extends AutoCloseable { * @return the Region or null if not found * @throws IllegalArgumentException if path is null, the empty string, or "/" */ - public <K, V> Region<K, V> getRegion(String path); + <K, V> Region<K, V> getRegion(String path); /** * Returns unmodifiable set of the root regions that are in the region service. This set is a @@ -67,7 +67,7 @@ public interface RegionService extends AutoCloseable { * * @return a Set of regions */ - public Set<Region<?, ?>> rootRegions(); + Set<Region<?, ?>> rootRegions(); // We did not have time to add this feature to 6.6.2 // /** @@ -96,7 +96,7 @@ public interface RegionService extends AutoCloseable { * @return the factory * @since GemFire 6.6.2 */ - public PdxInstanceFactory createPdxInstanceFactory(String className); + PdxInstanceFactory createPdxInstanceFactory(String className); /** * Creates and returns a PdxInstance that represents an enum value. @@ -108,14 +108,14 @@ public interface RegionService extends AutoCloseable { * @throws IllegalArgumentException if className or enumName are <code>null</code>. * @since GemFire 6.6.2 */ - public PdxInstance createPdxEnum(String className, String enumName, int enumOrdinal); + PdxInstance createPdxEnum(String className, String enumName, int enumOrdinal); /** * Return the QueryService for this region service. For a region service in a client the returned * QueryService will execute queries on the server. For a region service not in a client the * returned QueryService will execute queries on the local and peer regions. */ - public QueryService getQueryService(); + QueryService getQueryService(); /** * Terminates this region service and releases all its resources. Calls {@link Region#close} on @@ -125,7 +125,7 @@ public interface RegionService extends AutoCloseable { * * @throws CacheClosedException if the service is already closed. */ - public void close(); + void close(); /** * Indicates if this region service has been closed. After a new service is created, this method @@ -134,5 +134,5 @@ public interface RegionService extends AutoCloseable { * * @return true, if this service has just been created or has started to close; false, otherwise */ - public boolean isClosed(); + boolean isClosed(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/RoleEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/RoleEvent.java b/geode-core/src/main/java/org/apache/geode/cache/RoleEvent.java index cb1ba4a..e538de8 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/RoleEvent.java +++ b/geode-core/src/main/java/org/apache/geode/cache/RoleEvent.java @@ -29,6 +29,6 @@ public interface RoleEvent<K, V> extends RegionEvent<K, V> { /** * Returns the required roles that were lost or gained because of this event. */ - public Set<String> getRequiredRoles(); + Set<String> getRequiredRoles(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/SerializedCacheValue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/SerializedCacheValue.java b/geode-core/src/main/java/org/apache/geode/cache/SerializedCacheValue.java index a05dfac..99a22a9 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/SerializedCacheValue.java +++ b/geode-core/src/main/java/org/apache/geode/cache/SerializedCacheValue.java @@ -40,7 +40,7 @@ public interface SerializedCacheValue<V> { * EntryEvent that this serialize value was obtained from returns and this value does not * already have the serialized value. */ - public byte[] getSerializedValue(); + byte[] getSerializedValue(); /** * Returns the deserialized object for this cache value. @@ -49,5 +49,5 @@ public interface SerializedCacheValue<V> { * @throws IllegalStateException if off-heap and called after the method that was passed the * EntryEvent that this serialize value was obtained from returns. */ - public V getDeserializedValue(); + V getDeserializedValue(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/TransactionEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/TransactionEvent.java b/geode-core/src/main/java/org/apache/geode/cache/TransactionEvent.java index cb15f1b..5b4f4d7 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/TransactionEvent.java +++ b/geode-core/src/main/java/org/apache/geode/cache/TransactionEvent.java @@ -53,7 +53,7 @@ public interface TransactionEvent { * Gets the <code>TransactionId</code> associated this TransactionEvent. * */ - public TransactionId getTransactionId(); + TransactionId getTransactionId(); /** * Gets all "create" EntryEvents for this transaction; <code>Region.create</code> and/or @@ -63,7 +63,7 @@ public interface TransactionEvent { * @deprecated as of GemFire 5.0, use {@link #getEvents} instead */ @Deprecated - public List<EntryEvent<?, ?>> getCreateEvents(); + List<EntryEvent<?, ?>> getCreateEvents(); /** * Gets all "destroy" EntryEvents for this transaction; <code>Region.destroy</code> and @@ -73,7 +73,7 @@ public interface TransactionEvent { * @deprecated as of GemFire 5.0, use {@link #getEvents} instead */ @Deprecated - public List<EntryEvent<?, ?>> getDestroyEvents(); + List<EntryEvent<?, ?>> getDestroyEvents(); /** * Gets all <code>Region.put</code> EntryEvents for this transaction. @@ -82,7 +82,7 @@ public interface TransactionEvent { * @deprecated as of GemFire 5.0, use {@link #getEvents} instead */ @Deprecated - public List<EntryEvent<?, ?>> getPutEvents(); + List<EntryEvent<?, ?>> getPutEvents(); /** * Gets all "invalidate" EntryEvents for this transaction; <code>Region.invalidate</code> and @@ -92,7 +92,7 @@ public interface TransactionEvent { * @deprecated as of GemFire 5.0, use {@link #getEvents} instead */ @Deprecated - public List<EntryEvent<?, ?>> getInvalidateEvents(); + List<EntryEvent<?, ?>> getInvalidateEvents(); /** * Returns an ordered list of every {@link CacheEvent} for this transaction. The event order is @@ -102,13 +102,13 @@ public interface TransactionEvent { * operation performed by this transaction. * @since GemFire 5.0 */ - public List<CacheEvent<?, ?>> getEvents(); + List<CacheEvent<?, ?>> getEvents(); /** * Gets the Cache for this transaction event * * @return <code>Cache</code> */ - public Cache getCache(); + Cache getCache(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/TransactionListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/TransactionListener.java b/geode-core/src/main/java/org/apache/geode/cache/TransactionListener.java index 34f66e4..e8c974c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/TransactionListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/TransactionListener.java @@ -45,7 +45,7 @@ public interface TransactionListener extends CacheCallback { * @param event the TransactionEvent * @see CacheTransactionManager#commit */ - public void afterCommit(TransactionEvent event); + void afterCommit(TransactionEvent event); /** * Called after an unsuccessful commit operation. @@ -53,7 +53,7 @@ public interface TransactionListener extends CacheCallback { * @param event the TransactionEvent * @see CacheTransactionManager#commit */ - public void afterFailedCommit(TransactionEvent event); + void afterFailedCommit(TransactionEvent event); /** * Called after an explicit rollback of a transaction. @@ -62,5 +62,5 @@ public interface TransactionListener extends CacheCallback { * @see CacheTransactionManager#rollback * @see CacheTransactionManager#commit */ - public void afterRollback(TransactionEvent event); + void afterRollback(TransactionEvent event); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/TransactionWriter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/TransactionWriter.java b/geode-core/src/main/java/org/apache/geode/cache/TransactionWriter.java index 9e486ae..1665db3 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/TransactionWriter.java +++ b/geode-core/src/main/java/org/apache/geode/cache/TransactionWriter.java @@ -40,6 +40,6 @@ public interface TransactionWriter extends CacheCallback { * @see CacheTransactionManager#commit * @throws TransactionWriterException in the event that the transaction should be rolled back */ - public void beforeCommit(TransactionEvent event) throws TransactionWriterException; + void beforeCommit(TransactionEvent event) throws TransactionWriterException; } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEvent.java b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEvent.java index 78309ff..e4794a4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEvent.java +++ b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEvent.java @@ -26,7 +26,7 @@ public interface AsyncEvent<K, V> extends GatewayQueueEvent<K, V> { /** * Returns whether possibleDuplicate is set for this event. */ - public boolean getPossibleDuplicate(); + boolean getPossibleDuplicate(); /** * Returns the wrapper over the DistributedMembershipID, ThreadID, SequenceID which are used to @@ -34,5 +34,5 @@ public interface AsyncEvent<K, V> extends GatewayQueueEvent<K, V> { * events belonging to a unique producer. e.g. The EventID can be used to track events received by * <code>AsyncEventListener</code> to avoid processing duplicates. */ - public EventSequenceID getEventSequenceID(); + EventSequenceID getEventSequenceID(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventListener.java b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventListener.java index dadee04..d01fdfc 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventListener.java +++ b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventListener.java @@ -69,5 +69,5 @@ public interface AsyncEventListener extends CacheCallback { * @return boolean True represents whether the events were successfully processed, false * otherwise. */ - public boolean processEvents(List<AsyncEvent> events); + boolean processEvents(List<AsyncEvent> events); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueue.java b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueue.java index 574a912..e5408b4 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueue.java +++ b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueue.java @@ -31,21 +31,21 @@ public interface AsyncEventQueue { /** * @return String Id of the AsyncEventQueue */ - public String getId(); + String getId(); /** * The Disk store that is required for overflow and persistence * * @return String */ - public String getDiskStoreName();// for overflow and persistence + String getDiskStoreName();// for overflow and persistence /** * The maximum memory after which the data needs to be overflowed to disk. Default is 100 MB. * * @return int */ - public int getMaximumQueueMemory();// for overflow + int getMaximumQueueMemory();// for overflow /** * Represents the size of a batch that gets delivered over the AsyncEventQueue. Default batchSize @@ -53,7 +53,7 @@ public interface AsyncEventQueue { * * @return int */ - public int getBatchSize(); + int getBatchSize(); /** * Represents the maximum time interval that can elapse before a batch is sent from @@ -61,7 +61,7 @@ public interface AsyncEventQueue { * * @return int */ - public int getBatchTimeInterval(); + int getBatchTimeInterval(); /** * Represents whether batch conflation is enabled for batches sent from @@ -69,7 +69,7 @@ public interface AsyncEventQueue { * * @return boolean */ - public boolean isBatchConflationEnabled(); + boolean isBatchConflationEnabled(); /** * Represents whether the AsyncEventQueue is configured to be persistent or non-persistent. @@ -77,14 +77,14 @@ public interface AsyncEventQueue { * * @return boolean */ - public boolean isPersistent(); + boolean isPersistent(); /** * Represents whether writing to disk is synchronous or not. Default is true. * * @return boolean */ - public boolean isDiskSynchronous(); + boolean isDiskSynchronous(); /** * Represents whether the queue is primary or secondary. Events get delivered only by the primary @@ -93,7 +93,7 @@ public interface AsyncEventQueue { * * @return boolean */ - public boolean isPrimary(); + boolean isPrimary(); /** * The <code>AsyncEventListener</code> that is attached to the queue. All the event passing over @@ -101,14 +101,14 @@ public interface AsyncEventQueue { * * @return AsyncEventListener Implementation of AsyncEventListener */ - public AsyncEventListener getAsyncEventListener(); + AsyncEventListener getAsyncEventListener(); /** * Represents whether this queue is parallel (higher throughput) or serial. * * @return boolean True if the queue is parallel, false otherwise. */ - public boolean isParallel(); + boolean isParallel(); /** * Returns the number of dispatcher threads working for this <code>AsyncEventQueue</code>. Default @@ -116,7 +116,7 @@ public interface AsyncEventQueue { * * @return the number of dispatcher threads working for this <code>AsyncEventQueue</code> */ - public int getDispatcherThreads(); + int getDispatcherThreads(); /** * Returns the order policy followed while dispatching the events to AsyncEventListener. Order @@ -124,28 +124,28 @@ public interface AsyncEventQueue { * * @return the order policy followed while dispatching the events to AsyncEventListener. */ - public OrderPolicy getOrderPolicy(); + OrderPolicy getOrderPolicy(); /** * Returns the number of entries in this <code>AsyncEventQueue</code>. * * @return the number of entries in this <code>AsyncEventQueue</code>. */ - public int size(); + int size(); /** * Returns the <code>GatewayEventFilters</code> for this <code>AsyncEventQueue</code> * * @return the <code>GatewayEventFilters</code> for this <code>AsyncEventQueue</code> */ - public List<GatewayEventFilter> getGatewayEventFilters(); + List<GatewayEventFilter> getGatewayEventFilters(); /** * Returns the <code>GatewayEventSubstitutionFilter</code> for this <code>AsyncEventQueue</code> * * @return the <code>GatewayEventSubstitutionFilter</code> for this <code>AsyncEventQueue</code> */ - public GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter(); + GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter(); /** * Represents if expiration destroy operations are forwarded (passed) to @@ -153,6 +153,6 @@ public interface AsyncEventQueue { * * @return boolean True if expiration destroy operations are forwarded. */ - public boolean isForwardExpirationDestroy(); + boolean isForwardExpirationDestroy(); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueueFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueueFactory.java b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueueFactory.java index 8a09ca6..d1e822a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueueFactory.java +++ b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/AsyncEventQueueFactory.java @@ -52,7 +52,7 @@ public interface AsyncEventQueueFactory { * * @param name */ - public AsyncEventQueueFactory setDiskStoreName(String name); + AsyncEventQueueFactory setDiskStoreName(String name); /** * Sets the maximum amount of memory (in MB) for an <code>AsyncEventQueue</code>'s queue. Default @@ -60,7 +60,7 @@ public interface AsyncEventQueueFactory { * * @param memory The maximum amount of memory (in MB) for an <code>AsyncEventQueue</code>'s queue */ - public AsyncEventQueueFactory setMaximumQueueMemory(int memory); + AsyncEventQueueFactory setMaximumQueueMemory(int memory); /** * Sets whether or not the writing to the disk is synchronous. Default is true. @@ -68,14 +68,14 @@ public interface AsyncEventQueueFactory { * @param isSynchronous boolean if true indicates synchronous writes * */ - public AsyncEventQueueFactory setDiskSynchronous(boolean isSynchronous); + AsyncEventQueueFactory setDiskSynchronous(boolean isSynchronous); /** * Sets the batch size for an <code>AsyncEventQueue</code>'s queue. Default is 100. * * @param size The size of batches sent to its <code>AsyncEventListener</code> */ - public AsyncEventQueueFactory setBatchSize(int size); + AsyncEventQueueFactory setBatchSize(int size); /** * Sets the batch time interval (in milliseconds) for a <code>AsyncEventQueue</code>. Default is 5 @@ -84,14 +84,14 @@ public interface AsyncEventQueueFactory { * @param interval The maximum time interval that can elapse before a partial batch is sent from a * <code>AsyncEventQueue</code>. */ - public AsyncEventQueueFactory setBatchTimeInterval(int interval); + AsyncEventQueueFactory setBatchTimeInterval(int interval); /** * Sets whether the <code>AsyncEventQueue</code> is persistent or not. Default is false. * * @param isPersistent Whether to enable persistence for an <code>AsyncEventQueue</code>. */ - public AsyncEventQueueFactory setPersistent(boolean isPersistent); + AsyncEventQueueFactory setPersistent(boolean isPersistent); /** * Indicates whether all VMs need to distribute events to remote site. In this case only the @@ -100,7 +100,7 @@ public interface AsyncEventQueueFactory { * @param isParallel boolean to indicate whether distribution policy is parallel */ - public AsyncEventQueueFactory setParallel(boolean isParallel); + AsyncEventQueueFactory setParallel(boolean isParallel); /** * Sets whether to enable batch conflation for <code>AsyncEventQueue</code>. Default is false. @@ -108,14 +108,14 @@ public interface AsyncEventQueueFactory { * @param isConflation Whether or not to enable batch conflation for batches sent from a * <code>AsyncEventQueue</code> */ - public AsyncEventQueueFactory setBatchConflationEnabled(boolean isConflation); + AsyncEventQueueFactory setBatchConflationEnabled(boolean isConflation); /** * Sets the number of dispatcher thread. Default is 5. * * @param numThreads */ - public AsyncEventQueueFactory setDispatcherThreads(int numThreads); + AsyncEventQueueFactory setDispatcherThreads(int numThreads); /** * Adds a <code>GatewayEventFilter</code> to the attributes of AsyncEventQueue being created by @@ -123,7 +123,7 @@ public interface AsyncEventQueueFactory { * * @param filter GatewayEventFilter */ - public AsyncEventQueueFactory addGatewayEventFilter(GatewayEventFilter filter); + AsyncEventQueueFactory addGatewayEventFilter(GatewayEventFilter filter); /** * Removes the provided <code>GatewayEventFilter</code> from the attributes of AsyncEventQueue @@ -131,22 +131,21 @@ public interface AsyncEventQueueFactory { * * @param filter */ - public AsyncEventQueueFactory removeGatewayEventFilter(GatewayEventFilter filter); + AsyncEventQueueFactory removeGatewayEventFilter(GatewayEventFilter filter); /** * Sets the order policy for multiple dispatchers. Default is KEY. * * @param policy */ - public AsyncEventQueueFactory setOrderPolicy(OrderPolicy policy); + AsyncEventQueueFactory setOrderPolicy(OrderPolicy policy); /** * Sets the <code>GatewayEventSubstitutionFilter</code>. * * @param filter The <code>GatewayEventSubstitutionFilter</code> */ - public AsyncEventQueueFactory setGatewayEventSubstitutionListener( - GatewayEventSubstitutionFilter filter); + AsyncEventQueueFactory setGatewayEventSubstitutionListener(GatewayEventSubstitutionFilter filter); /** * Forwards destroy operations from expiration action to AsyncEventQueue. By default the @@ -155,7 +154,7 @@ public interface AsyncEventQueueFactory { * * @param forward boolean to indicate whether to forward expiration destroy events. */ - public AsyncEventQueueFactory setForwardExpirationDestroy(boolean forward); + AsyncEventQueueFactory setForwardExpirationDestroy(boolean forward); /** * Creates the <code>AsyncEventQueue</code>. It accepts Id of AsyncEventQueue and instance of @@ -169,5 +168,5 @@ public interface AsyncEventQueueFactory { * @param listener <code>AsyncEventListener</code> to be added to the regions that are configured * to use this queue. */ - public AsyncEventQueue create(String id, AsyncEventListener listener); + AsyncEventQueue create(String id, AsyncEventListener listener); } http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/geode-core/src/main/java/org/apache/geode/cache/client/ClientCache.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/ClientCache.java b/geode-core/src/main/java/org/apache/geode/cache/client/ClientCache.java index 14655e6..0c0be18 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/ClientCache.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/ClientCache.java @@ -58,13 +58,13 @@ public interface ClientCache extends GemFireCache { * Return the QueryService for the named pool. The query operations performed using this * QueryService will be executed on the servers that are associated with this pool. */ - public QueryService getQueryService(String poolName); + QueryService getQueryService(String poolName); /** * Return a QueryService that queries the local state in the client cache. These queries will not * be sent to a server. */ - public QueryService getLocalQueryService(); + QueryService getLocalQueryService(); /** * Terminates this object cache and releases all the resources. Calls {@link Region#close} on each @@ -75,7 +75,7 @@ public interface ClientCache extends GemFireCache { * timeout period * @throws CacheClosedException if the cache is already closed. */ - public void close(boolean keepalive); + void close(boolean keepalive); /** * Create and return a client region factory that is initialized to create a region using the @@ -84,7 +84,7 @@ public interface ClientCache extends GemFireCache { * @param shortcut the predefined region attributes to initialize the factory with. * @return a factory that will produce a client region. */ - public <K, V> ClientRegionFactory<K, V> createClientRegionFactory(ClientRegionShortcut shortcut); + <K, V> ClientRegionFactory<K, V> createClientRegionFactory(ClientRegionShortcut shortcut); /** * Create and return a client region factory that is initialized to create a region using the @@ -97,7 +97,7 @@ public interface ClientCache extends GemFireCache { * @throws IllegalStateException if named region attributes has not been defined. * @return a factory that will produce a client region. */ - public <K, V> ClientRegionFactory<K, V> createClientRegionFactory(String regionAttributesId); + <K, V> ClientRegionFactory<K, V> createClientRegionFactory(String regionAttributesId); /** * Notifies the server that this durable client is ready to receive updates. This method is used @@ -112,7 +112,7 @@ public interface ClientCache extends GemFireCache { * * @throws IllegalStateException if called by a non-durable client */ - public void readyForEvents(); + void readyForEvents(); /** * Creates an authenticated cache view using the given user security properties on the client @@ -134,7 +134,7 @@ public interface ClientCache extends GemFireCache { * @return the {@link RegionService} instance associated with a user and the given properties. * @throws UnsupportedOperationException when invoked with multiuser-authentication as false. */ - public RegionService createAuthenticatedView(Properties userSecurityProperties); + RegionService createAuthenticatedView(Properties userSecurityProperties); /** * Creates an authenticated cache view using the given user security properties using the given @@ -149,14 +149,14 @@ public interface ClientCache extends GemFireCache { * @param poolName - the pool that the users should be authenticated against. * @return the {@link RegionService} instance associated with a user and the given properties. */ - public RegionService createAuthenticatedView(Properties userSecurityProperties, String poolName); + RegionService createAuthenticatedView(Properties userSecurityProperties, String poolName); /** * Returns a set of the servers to which this client is currently connected. * * @since GemFire 6.6 */ - public Set<InetSocketAddress> getCurrentServers(); + Set<InetSocketAddress> getCurrentServers(); /** * Returns the default server pool. If one or more non-default pools were configured, this may @@ -165,6 +165,6 @@ public interface ClientCache extends GemFireCache { * @since GemFire 7.0 * @see org.apache.geode.cache.client.Pool */ - public Pool getDefaultPool(); + Pool getDefaultPool(); }
