Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

WAN publisher SPI cleanup, part 2 #15195

Merged
merged 1 commit into from
Jun 26, 2019
Merged

WAN publisher SPI cleanup, part 2 #15195

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion hazelcast-spring/src/test/java/com/hazelcast/spring/TestFullApplicationContext.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -985,7 +985,7 @@ public void testWanReplicationConfig() {
WanPublisherConfig publisherConfig = wcfg.getWanPublisherConfigs().get(0);
assertEquals("tokyo", publisherConfig.getGroupName());
assertEquals("tokyoPublisherId", publisherConfig.getPublisherId());
assertEquals("com.hazelcast.enterprise.wan.replication.WanBatchReplication", publisherConfig.getClassName());
assertEquals("com.hazelcast.enterprise.wan.impl.replication.WanBatchReplication", publisherConfig.getClassName());
assertEquals(WANQueueFullBehavior.THROW_EXCEPTION, publisherConfig.getQueueFullBehavior());
assertEquals(WanPublisherState.STOPPED, publisherConfig.getInitialPublisherState());
assertEquals(1000, publisherConfig.getQueueCapacity());
Expand Down
4 changes: 2 additions & 2 deletions ...est/resources/com/hazelcast/spring/advancedNetworkConfig-applicationContext-hazelcast.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@
<hz:wan-replication name="testWan">
<hz:wan-publisher group-name="tokyo"
publisher-id="tokyoPublisherId"
class-name="com.hazelcast.enterprise.wan.replication.WanBatchReplication">
class-name="com.hazelcast.enterprise.wan.impl.replication.WanBatchReplication">
<hz:queue-full-behavior>THROW_EXCEPTION</hz:queue-full-behavior>
<hz:queue-capacity>1000</hz:queue-capacity>
<hz:initial-publisher-state>STOPPED</hz:initial-publisher-state>
Expand Down Expand Up @@ -100,7 +100,7 @@
<hz:property name="maxEndpoints">2</hz:property>
</hz:properties>
</hz:wan-publisher>
<hz:wan-publisher group-name="ankara" class-name="com.hazelcast.enterprise.wan.replication.WanBatchReplication">
<hz:wan-publisher group-name="ankara" class-name="com.hazelcast.enterprise.wan.impl.replication.WanBatchReplication">
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Referencing an impl class doesn't seem ideal. If we never expect a publisher implemented by user, hiding it completely can be a good option.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think even if the user can implement it, this class can be resolved internally without forcing the user to set it. This class is not even designed for extension, so 👍 for making it private.

Copy link
Contributor Author

@mmedenjak mmedenjak Jun 26, 2019 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, it was one of the things that I was a bit concerned about but not too much. For one, it definitely is internal in the sense that we don't support the user to instantiating it using new com.hazelcast.enterprise.wan.impl.replication.WanBatchReplication(); and using it somewhere in their code. It's our internal implementation and it's satisfactory for most users using WAN.

The problem here may be that we require the fully qualified class name. I was thinking that we might add some aliases like WanBatchReplication so it's easier to configure and easier on the eyes. The other idea was simply to make it the default as most users will use it anyway. So this could work then:

<hz:wan-publisher group-name="ankara">
...
</hz:wan-publisher>

But either of these ideas would be part of a subsequent PR, not this one. WDYT?

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

One more thought. Maybe instead of the FQCN of the endpoint implementation, we should accept a factory's FQCN. So that additional dependencies can be injected in the way the user likes.

<hz:queue-capacity>${wan.queue.capacity}</hz:queue-capacity>
</hz:wan-publisher>
<hz:wan-consumer class-name="com.hazelcast.wan.custom.WanConsumer"
Expand Down
4 changes: 2 additions & 2 deletions ...pring/src/test/resources/com/hazelcast/spring/fullConfig-applicationContext-hazelcast.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@
<hz:wan-replication name="testWan">
<hz:wan-publisher group-name="tokyo"
publisher-id="tokyoPublisherId"
class-name="com.hazelcast.enterprise.wan.replication.WanBatchReplication">
class-name="com.hazelcast.enterprise.wan.impl.replication.WanBatchReplication">
<hz:queue-full-behavior>THROW_EXCEPTION</hz:queue-full-behavior>
<hz:queue-capacity>1000</hz:queue-capacity>
<hz:initial-publisher-state>STOPPED</hz:initial-publisher-state>
Expand Down Expand Up @@ -127,7 +127,7 @@
<hz:property name="maxEndpoints">2</hz:property>
</hz:properties>
</hz:wan-publisher>
<hz:wan-publisher group-name="ankara" class-name="com.hazelcast.enterprise.wan.replication.WanBatchReplication">
<hz:wan-publisher group-name="ankara" class-name="com.hazelcast.enterprise.wan.impl.replication.WanBatchReplication">
<hz:queue-capacity>${wan.queue.capacity}</hz:queue-capacity>
</hz:wan-publisher>
<hz:wan-consumer class-name="com.hazelcast.wan.custom.WanConsumer"
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@
import com.hazelcast.util.FutureUtil;
import com.hazelcast.util.MapUtil;
import com.hazelcast.util.ServiceLoader;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;
import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;

import javax.cache.CacheException;
Expand Down
4 changes: 3 additions & 1 deletion hazelcast/src/main/java/com/hazelcast/config/WanPublisherState.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,8 @@

package com.hazelcast.config;

import com.hazelcast.wan.impl.WanReplicationService;

/**
* Defines the state in which a WAN publisher can be in if it is not shutting
* down.
Expand Down Expand Up @@ -54,7 +56,7 @@ public enum WanPublisherState {
* it will become available. Once it becomes available, you can then switch
* the publisher state to REPLICATING to begin replicating to that cluster.
*
* @see com.hazelcast.wan.WanReplicationService#clearQueues(String, String)
* @see WanReplicationService#clearQueues(String, String)
*/
STOPPED((byte) 2, false, false);

Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/instance/impl/DefaultNodeExtension.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@
import com.hazelcast.util.UuidUtil;
import com.hazelcast.version.MemberVersion;
import com.hazelcast.version.Version;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationServiceImpl;

import java.util.Collections;
Expand Down
4 changes: 2 additions & 2 deletions hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpPostCommandProcessor.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,8 @@
import com.hazelcast.util.JsonUtil;
import com.hazelcast.util.StringUtil;
import com.hazelcast.version.Version;
import com.hazelcast.wan.AddWanConfigResult;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.AddWanConfigResult;
import com.hazelcast.wan.impl.WanReplicationService;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/internal/jmx/InstanceMBean.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
import com.hazelcast.monitor.LocalWanStats;
import com.hazelcast.spi.ExecutionService;
import com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

import java.io.File;
import java.net.URL;
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/internal/jmx/WanPublisherMBean.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

import com.hazelcast.monitor.LocalWanPublisherStats;
import com.hazelcast.monitor.LocalWanStats;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

import java.util.Map;

Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/internal/management/TimedMemberStateFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@
import com.hazelcast.spi.partition.IPartition;
import com.hazelcast.topic.impl.TopicService;
import com.hazelcast.topic.impl.reliable.ReliableTopicService;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

import java.util.ArrayList;
import java.util.Collection;
Expand Down
2 changes: 1 addition & 1 deletion ...st/src/main/java/com/hazelcast/internal/management/operation/ChangeWanStateOperation.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import com.hazelcast.config.WanPublisherState;
import com.hazelcast.spi.impl.operationservice.AbstractLocalOperation;
import com.hazelcast.spi.NodeEngine;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

/**
* Stop, pause or resume WAN replication for the given {@code wanReplicationName} and {@code targetGroupName}.
Expand Down
2 changes: 1 addition & 1 deletion ...st/src/main/java/com/hazelcast/internal/management/operation/ClearWanQueuesOperation.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

import com.hazelcast.spi.impl.operationservice.AbstractLocalOperation;
import com.hazelcast.spi.NodeEngine;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

/**
* Clear WAN replication queues for the given wan replication schema and publisher
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/com/hazelcast/internal/management/operation/WanCheckConsistencyOperation.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

import com.hazelcast.spi.impl.operationservice.AbstractLocalOperation;
import com.hazelcast.spi.NodeEngine;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

/**
* Checking consistency of the given map for the given wan replication
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@
import com.hazelcast.util.MemoryInfoAccessor;
import com.hazelcast.util.RuntimeMemoryInfoAccessor;
import com.hazelcast.wan.WanReplicationPublisher;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

import java.util.HashMap;
import java.util.Map;
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/map/impl/MapReplicationSupportingService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
import com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes;
import com.hazelcast.spi.serialization.SerializationService;
import com.hazelcast.wan.WanReplicationEvent;
import com.hazelcast.wan.impl.DistributedServiceWanEventCounters;
import com.hazelcast.wan.DistributedServiceWanEventCounters;

import java.util.concurrent.Future;

Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/map/impl/MerkleTreeNodeEntries.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import com.hazelcast.nio.ObjectDataOutput;
import com.hazelcast.nio.serialization.Data;
import com.hazelcast.nio.serialization.IdentifiedDataSerializable;
import com.hazelcast.wan.merkletree.MerkleTree;
import com.hazelcast.wan.impl.merkletree.MerkleTree;

import java.io.IOException;
import java.util.Collections;
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/map/impl/wan/MapReplicationRemove.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
import com.hazelcast.nio.serialization.Data;
import com.hazelcast.nio.serialization.IdentifiedDataSerializable;
import com.hazelcast.wan.ReplicationEventObject;
import com.hazelcast.wan.impl.DistributedServiceWanEventCounters;
import com.hazelcast.wan.DistributedServiceWanEventCounters;
import com.hazelcast.wan.impl.WanDataSerializerHook;

import java.io.IOException;
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/map/impl/wan/MapReplicationUpdate.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
import com.hazelcast.nio.serialization.Data;
import com.hazelcast.nio.serialization.IdentifiedDataSerializable;
import com.hazelcast.wan.ReplicationEventObject;
import com.hazelcast.wan.impl.DistributedServiceWanEventCounters;
import com.hazelcast.wan.DistributedServiceWanEventCounters;
import com.hazelcast.wan.impl.WanDataSerializerHook;

import java.io.IOException;
Expand Down
9 changes: 5 additions & 4 deletions hazelcast/src/main/java/com/hazelcast/monitor/LocalWanPublisherStats.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,10 @@

import com.hazelcast.config.WanPublisherState;
import com.hazelcast.internal.management.JsonSerializable;
import com.hazelcast.wan.impl.DistributedServiceWanEventCounters.DistributedObjectWanEventCounters;
import com.hazelcast.wan.DistributedServiceWanEventCounters.DistributedObjectWanEventCounters;
import com.hazelcast.wan.WanSyncStats;
import com.hazelcast.wan.merkletree.ConsistencyCheckResult;
import com.hazelcast.wan.ConsistencyCheckResult;
import com.hazelcast.wan.impl.WanReplicationService;

import java.util.Map;

Expand Down Expand Up @@ -62,8 +63,8 @@ public interface LocalWanPublisherStats extends JsonSerializable {
/**
* Returns the current {@link WanPublisherState} of this publisher.
*
* @see com.hazelcast.wan.WanReplicationService#pause(String, String)
* @see com.hazelcast.wan.WanReplicationService#stop(String, String)
* @see WanReplicationService#pause(String, String)
* @see WanReplicationService#stop(String, String)
*/
WanPublisherState getPublisherState();

Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/monitor/WanSyncState.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

package com.hazelcast.monitor;

import com.hazelcast.wan.WanSyncStatus;
import com.hazelcast.wan.impl.WanSyncStatus;

/**
* Local WAN sync statistics to be used by {@link MemberState} implementations.
Expand Down
4 changes: 2 additions & 2 deletions hazelcast/src/main/java/com/hazelcast/monitor/impl/LocalWanPublisherStatsImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@
import com.hazelcast.config.WanPublisherState;
import com.hazelcast.internal.json.JsonObject;
import com.hazelcast.monitor.LocalWanPublisherStats;
import com.hazelcast.wan.impl.DistributedServiceWanEventCounters.DistributedObjectWanEventCounters;
import com.hazelcast.wan.DistributedServiceWanEventCounters.DistributedObjectWanEventCounters;
import com.hazelcast.wan.WanSyncStats;
import com.hazelcast.wan.merkletree.ConsistencyCheckResult;
import com.hazelcast.wan.ConsistencyCheckResult;

import java.util.Map;
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/monitor/impl/WanSyncStateImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import com.hazelcast.internal.json.JsonObject;
import com.hazelcast.monitor.WanSyncState;
import com.hazelcast.util.Clock;
import com.hazelcast.wan.WanSyncStatus;
import com.hazelcast.wan.impl.WanSyncStatus;

public class WanSyncStateImpl implements WanSyncState {

Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/spi/NodeEngine.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
import com.hazelcast.spi.serialization.SerializationService;
import com.hazelcast.transaction.TransactionManagerService;
import com.hazelcast.version.MemberVersion;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

import java.util.Collection;

Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngineImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@
import com.hazelcast.transaction.TransactionManagerService;
import com.hazelcast.transaction.impl.TransactionManagerServiceImpl;
import com.hazelcast.version.MemberVersion;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

import javax.annotation.Nonnull;
import java.util.Collection;
Expand Down
2 changes: 1 addition & 1 deletion hazelcast/src/main/java/com/hazelcast/spi/impl/servicemanager/impl/ServiceManagerImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@
import com.hazelcast.transaction.impl.TransactionManagerServiceImpl;
import com.hazelcast.transaction.impl.xa.XAService;
import com.hazelcast.util.ServiceLoader;
import com.hazelcast.wan.WanReplicationService;
import com.hazelcast.wan.impl.WanReplicationService;

import java.lang.reflect.Constructor;
import java.util.Collection;
Expand Down
2 changes: 1 addition & 1 deletion ...an/merkletree/ConsistencyCheckResult.java → ...hazelcast/wan/ConsistencyCheckResult.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan.merkletree;
package com.hazelcast.wan;

/**
* Result of the last WAN consistency check result
Expand Down
2 changes: 1 addition & 1 deletion ...l/DistributedServiceWanEventCounters.java → ...n/DistributedServiceWanEventCounters.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan.impl;
package com.hazelcast.wan;

import com.hazelcast.util.ConstructorFunction;

Expand Down
1 change: 0 additions & 1 deletion hazelcast/src/main/java/com/hazelcast/wan/ReplicationEventObject.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@
package com.hazelcast.wan;

import com.hazelcast.nio.serialization.Data;
import com.hazelcast.wan.impl.DistributedServiceWanEventCounters;

/**
* Interface for all WAN replication messages
Expand Down
2 changes: 1 addition & 1 deletion ...com/hazelcast/wan/AddWanConfigResult.java → ...azelcast/wan/impl/AddWanConfigResult.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan;
package com.hazelcast.wan.impl;

import com.hazelcast.util.Preconditions;

Expand Down
1 change: 1 addition & 0 deletions hazelcast/src/main/java/com/hazelcast/wan/impl/WanEventCounters.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
import com.hazelcast.cache.impl.CacheService;
import com.hazelcast.map.impl.MapService;
import com.hazelcast.util.ConstructorFunction;
import com.hazelcast.wan.DistributedServiceWanEventCounters;

import java.util.concurrent.ConcurrentHashMap;

Expand Down
5 changes: 3 additions & 2 deletions .../hazelcast/wan/WanReplicationService.java → ...lcast/wan/impl/WanReplicationService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,15 +14,16 @@
* limitations under the License.
*/

package com.hazelcast.wan;
package com.hazelcast.wan.impl;

import com.hazelcast.config.InvalidConfigurationException;
import com.hazelcast.config.WanReplicationConfig;
import com.hazelcast.monitor.LocalWanStats;
import com.hazelcast.monitor.WanSyncState;
import com.hazelcast.spi.CoreService;
import com.hazelcast.spi.StatisticsAwareService;
import com.hazelcast.wan.impl.DistributedServiceWanEventCounters;
import com.hazelcast.wan.WanReplicationPublisher;
import com.hazelcast.wan.DistributedServiceWanEventCounters;

/**
* This is the WAN replications service API core interface. The
Expand Down
5 changes: 2 additions & 3 deletions hazelcast/src/main/java/com/hazelcast/wan/impl/WanReplicationServiceImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,10 +26,9 @@
import com.hazelcast.monitor.LocalWanStats;
import com.hazelcast.monitor.WanSyncState;
import com.hazelcast.util.ConstructorFunction;
import com.hazelcast.wan.AddWanConfigResult;
import com.hazelcast.wan.DistributedServiceWanEventCounters;
import com.hazelcast.wan.WanReplicationEndpoint;
import com.hazelcast.wan.WanReplicationPublisher;
import com.hazelcast.wan.WanReplicationService;

import java.util.List;
import java.util.Map;
Expand All @@ -39,7 +38,7 @@
import static com.hazelcast.util.ConcurrencyUtil.getOrPutSynchronized;

/**
* Open source implementation of the {@link com.hazelcast.wan.WanReplicationService}
* Open source implementation of the {@link WanReplicationService}
*/
public class WanReplicationServiceImpl implements WanReplicationService {

Expand Down
2 changes: 1 addition & 1 deletion ...java/com/hazelcast/wan/WanSyncStatus.java → ...com/hazelcast/wan/impl/WanSyncStatus.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan;
package com.hazelcast.wan.impl;

/**
* {@code WanSyncStatus} shows the current status of WAN sync.
Expand Down
2 changes: 1 addition & 1 deletion ...an/merkletree/AbstractMerkleTreeView.java → ...pl/merkletree/AbstractMerkleTreeView.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan.merkletree;
package com.hazelcast.wan.impl.merkletree;

/**
* Base class for the {@link MerkleTreeView} implementations
Expand Down
2 changes: 1 addition & 1 deletion ...lcast/wan/merkletree/ArrayMerkleTree.java → .../wan/impl/merkletree/ArrayMerkleTree.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan.merkletree;
package com.hazelcast.wan.impl.merkletree;

import com.hazelcast.util.collection.OAHashSet;

Expand Down
2 changes: 1 addition & 1 deletion .../hazelcast/wan/merkletree/MerkleTree.java → ...lcast/wan/impl/merkletree/MerkleTree.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan.merkletree;
package com.hazelcast.wan.impl.merkletree;

import java.util.function.Consumer;

Expand Down
2 changes: 1 addition & 1 deletion ...elcast/wan/merkletree/MerkleTreeUtil.java → ...t/wan/impl/merkletree/MerkleTreeUtil.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package com.hazelcast.wan.merkletree;
package com.hazelcast.wan.impl.merkletree;

import com.hazelcast.util.QuickMath;

Expand Down
Loading