ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [2/3] incubator-ignite git commit: # Renaming
Date Fri, 05 Dec 2014 10:56:16 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubLoadBalancingMode.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubLoadBalancingMode.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubLoadBalancingMode.java
deleted file mode 100644
index adac6a4..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubLoadBalancingMode.java
+++ /dev/null
@@ -1,26 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.receiver;
-
-/**
- * Data center replication receiver hub load balancing mode. Determines to which receiver hub from the given remote
- * data center the next batch will be sent from the sender hub.
- */
-public enum GridDrReceiverHubLoadBalancingMode {
-    /**
-     * Balance receiver hubs in random fashion.
-     */
-    DR_RANDOM,
-
-    /**
-     * Balance receiver hubs in round-robin fashion.
-     */
-    DR_ROUND_ROBIN
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubMBean.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubMBean.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubMBean.java
deleted file mode 100644
index 5cb6299..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubMBean.java
+++ /dev/null
@@ -1,122 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.receiver;
-
-import org.apache.ignite.mbean.*;
-
-/**
- * This interface defines JMX view on data center replication receiver hub.
- */
-@IgniteMBeanDescription("MBean that provides access to receiver hub descriptor.")
-public interface GridDrReceiverHubMBean {
-    /**
-     * Get metrics (statistics) for this receiver hub.
-     *
-     * @return Receiver hub metrics.
-     */
-    @IgniteMBeanDescription("Formatted receiver hub metrics.")
-    public String metricsFormatted();
-
-    /**
-     * Gets local host name receiving hub server is bound to.
-     *
-     * @return Local host name.
-     */
-    @IgniteMBeanDescription("Local hostname.")
-    public String getLocalInboundHost();
-
-    /**
-     * Gets local port receiver hub is bound to.
-     *
-     * @return Local port.
-     */
-    @IgniteMBeanDescription("Local port.")
-    public int getLocalInboundPort();
-
-    /**
-     * Gets number of selector threads in receiver hub's TCP server.
-     *
-     * @return Amount of server NIO threads.
-     */
-    @IgniteMBeanDescription("Number of selector threads in receiver hub's TCP server.")
-    public int getSelectorCount();
-
-    /**
-     * Gets number of threads responsible for sender hub requests processing.
-     *
-     * @return Amount of server worker threads.
-     */
-    @IgniteMBeanDescription("Amount of server worker threads.")
-    public int getWorkerThreads();
-
-    /**
-     * Gets message queue limit for incoming and outgoing messages.
-     *
-     * @return Message queue limit.
-     */
-    @IgniteMBeanDescription("Message queue limit for incoming and outgoing messages.")
-    public int getMessageQueueLimit();
-
-    /**
-     * Whether to use TCP_NODELAY mode.
-     *
-     * @return TCP_NODELAY mode flag.
-     */
-    @IgniteMBeanDescription("TCP_NODELAY mode flag.")
-    public boolean isTcpNodelay();
-
-    /**
-     * Whether to use direct buffer when processing sender hub requests.
-     *
-     * @return Direct buffer flag.
-     */
-    @IgniteMBeanDescription("Direct buffer flag.")
-    public boolean isDirectBuffer();
-
-    /**
-     * Gets idle timeout for sender hub socket connection.
-     *
-     * @return Idle timeout for sender hub socket connection.
-     */
-    @IgniteMBeanDescription("Idle timeout for sender hub socket connection.")
-    public long getIdleTimeout();
-
-    /**
-     * Gets write timeout for sender hub socket connection.
-     *
-     * @return Write timeout.
-     */
-    @IgniteMBeanDescription("Write timeout for sender hub socket connection.")
-    public long getWriteTimeout();
-
-    /**
-     * Gets data center replication data loader flush frequency.
-     *
-     * @return Data flush frequency.
-     */
-    @IgniteMBeanDescription("Data flush frequency.")
-    public long getFlushFrequency();
-
-    /**
-     * Gets data center replication data loader per node buffer size.
-     *
-     * @return Buffer size.
-     */
-    @IgniteMBeanDescription("DR data loader per node buffer size.")
-    public int getPerNodeBufferSize();
-
-    /**
-     * Gets per node parallel load operations.
-     *
-     * @return Per node parallel load operations.
-     */
-    @IgniteMBeanDescription("Parallel load operations per node.")
-    public int getPerNodeParallelLoadOperations();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubOutMetrics.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubOutMetrics.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubOutMetrics.java
deleted file mode 100644
index 506645c..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/GridDrReceiverHubOutMetrics.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.receiver;
-
-/**
- * Data center replication receiver hub metrics for outgoing data, i.e. data transferred from receiver hub to
- * receiver caches.
- */
-public interface GridDrReceiverHubOutMetrics {
-    /**
-     * Gets amount of batches waiting to be stored in receiver caches.
-     *
-     * @return Amount of batches waiting to be stored in receiver caches.
-     */
-    public int batchesSent();
-
-    /**
-     * Gets amount of entries waiting to be stored in receiver caches.
-     *
-     * @return Amount of entries waiting to be stored in receiver caches.
-     */
-    public long entriesSent();
-
-    /**
-     * Gets amount of bytes waiting to be stored.
-     *
-     * @return Amount of bytes waiting to be stored.
-     */
-    public long bytesSent();
-
-    /**
-     * Gets amount of batches stored in receiver caches.
-     *
-     * @return Amount of batches stored in receiver caches.
-     */
-    public int batchesAcked();
-
-    /**
-     * Gets amount of cache entries stored in receiver caches.
-     *
-     * @return Amount of cache entries stored in receiver caches.
-     */
-    public long entriesAcked();
-
-    /**
-     * Gets amount of bytes stored in receiver caches.
-     *
-     * @return Amount of bytes stored in receiver caches.
-     */
-    public long bytesAcked();
-
-    /**
-     * Gets average time in milliseconds between sending batch to receiver cache nodes and successfully storing it.
-     *
-     * @return Average time in milliseconds between sending batch to receiver cache nodes and successfully storing it.
-     */
-    public double averageBatchAckTime();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/package.html b/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/package.html
deleted file mode 100644
index e9a0305..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/receiver/package.html
+++ /dev/null
@@ -1,17 +0,0 @@
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!--
-    @html.file.header
-    _________        _____ __________________        _____
-    __  ____/___________(_)______  /__  ____/______ ____(_)_______
-    _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
-    / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
-    \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
--->
-<html>
-<body>
-    <img alt="icon" class="javadocimg" src="{@docRoot}/img/cube.gif"/>
-    Data center replication-related interfaces and classes for receiver hubs.
-    <p>
-    @html.java.package
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConfiguration.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConfiguration.java
deleted file mode 100644
index 09507fc..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConfiguration.java
+++ /dev/null
@@ -1,334 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender;
-
-import org.gridgain.grid.dr.hub.sender.store.*;
-import org.gridgain.grid.util.typedef.internal.*;
-import org.jetbrains.annotations.*;
-
-import java.util.*;
-
-import org.gridgain.grid.dr.hub.sender.store.memory.*;
-
-/**
- * Data center replication sender hub configuration.
- */
-public class GridDrSenderHubConfiguration {
-    /** Default maximum failed connect attempts. */
-    public static final int DFLT_MAX_FAILED_CONNECT_ATTEMPTS = 5;
-
-    /** Default maximum processing errors. */
-    public static final int DFLT_MAX_ERRORS = 10;
-
-    /** Default health check frequency. */
-    public static final long DFLT_HEALTH_CHECK_FREQ = 2000L;
-
-    /** Default ping timeout. */
-    public static final long DFLT_SYS_REQ_TIMEOUT = 5000L;
-
-    /** Default read timeout. */
-    public static final long DFLT_READ_TIMEOUT = 5000L;
-
-    /** Default maximum amount of enqueued requests per remote receiver hub. */
-    public static final int DFLT_MAX_QUEUE_SIZE = 100;
-
-    /** Reconnect on error timeout. */
-    public static final long DFLT_RECONNECT_ON_FAILURE_TIMEOUT = 5000L;
-
-    /** Replicas with which this sender hub will communicate. */
-    private GridDrSenderHubConnectionConfiguration[] connCfg;
-
-    /** Maximum failed connection attempts after which remote sender hub is considered to be offline. */
-    private int maxFailedConnectAttempts = DFLT_MAX_FAILED_CONNECT_ATTEMPTS;
-
-    /** Maximum processing errors received from replication hub before it is considered to be offline. */
-    private int maxErrors = DFLT_MAX_ERRORS;
-
-    /** Receiving hubs health check frequency. */
-    private long healthCheckFreq = DFLT_HEALTH_CHECK_FREQ;
-
-    /** Ping timeout. */
-    private long sysReqTimeout = DFLT_SYS_REQ_TIMEOUT;
-
-    /** Read timeout. */
-    private long readTimeout = DFLT_READ_TIMEOUT;
-
-    /** Maximum queue size. */
-    private int maxQueueSize = DFLT_MAX_QUEUE_SIZE;
-
-    /** Reconnect-on-failure timeout. */
-    private long reconnOnFailureTimeout = DFLT_RECONNECT_ON_FAILURE_TIMEOUT;
-
-    /** Cache names this sender hub works with. */
-    private String[] cacheNames;
-
-    /** Store. */
-    private GridDrSenderHubStore store;
-
-    /**
-     * Default constructor.
-     */
-    public GridDrSenderHubConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copying constructor.
-     *
-     * @param cfg Another sender hub configuration.
-     */
-    public GridDrSenderHubConfiguration(GridDrSenderHubConfiguration cfg) {
-        cacheNames = cfg.getCacheNames();
-        healthCheckFreq = cfg.getHealthCheckFrequency();
-        maxErrors = cfg.getMaxErrors();
-        maxFailedConnectAttempts = cfg.getMaxFailedConnectAttempts();
-        maxQueueSize = cfg.getMaxQueueSize();
-        store = cfg.getStore();
-        readTimeout = cfg.getReadTimeout();
-        reconnOnFailureTimeout = cfg.getReconnectOnFailureTimeout();
-        connCfg = cfg.getConnectionConfiguration();
-        sysReqTimeout = cfg.getSystemRequestTimeout();
-    }
-
-    /**
-     * Get remote data center connection configurations. Defines data centers this sender hubs will work with.
-     *
-     * @return Remote data center connection configurations.
-     */
-    public GridDrSenderHubConnectionConfiguration[] getConnectionConfiguration() {
-        return connCfg;
-    }
-
-    /**
-     * Set remote data center connection configurations. See {@link #getConnectionConfiguration()} for more
-     * information.
-     *
-     * @param connCfg Remote data center connection configurations.
-     */
-    public void setConnectionConfiguration(GridDrSenderHubConnectionConfiguration... connCfg) {
-        this.connCfg = connCfg;
-    }
-
-    /**
-     * Gets maximum failed connect attempts. Once amount of failed sequential attmepts to connect to particular
-     * remote receiver hubs exceeds this limit, receiver hub will be considered offline. Further attempts to
-     * re-establish connection to this receiver hub will be performed according to
-     * {@link #getReconnectOnFailureTimeout()} property.
-     * <p>
-     * Defaults to {@link #DFLT_MAX_FAILED_CONNECT_ATTEMPTS}.
-     *
-     * @return Maximum failed connect attempts.
-     */
-    public int getMaxFailedConnectAttempts() {
-        return maxFailedConnectAttempts;
-    }
-
-    /**
-     * Set maximum failed connect attempts. See {@link #getMaxFailedConnectAttempts()} for more information.
-     *
-     * @param maxFailedConnectAttempts Maximum failed connect attempts.
-     */
-    public void setMaxFailedConnectAttempts(int maxFailedConnectAttempts) {
-        this.maxFailedConnectAttempts = maxFailedConnectAttempts;
-    }
-
-    /**
-     * Gets maximum amount of sequential errors in receiver hub responses. When this threshold is reached, connection
-     * to this faulty receiver hub will be closed and reciver hub will be considered offline. Further attempts to
-     * re-establish connection to this receiver hub will be performed according to
-     * {@link #getReconnectOnFailureTimeout()} property.
-     * <p>
-     * Defaults to {@link #DFLT_MAX_ERRORS}.
-     *
-     * @return Maximum amount of sequential errors in receiver hub responses
-     */
-    public int getMaxErrors() {
-        return maxErrors;
-    }
-
-    /**
-     * Sets maximum amount of sequential errors in receiver hub responses. See {@link #getMaxErrors()} for more
-     * information.
-     *
-     * @param maxErrors Maximum amount of sequential errors in receiver hub responses
-     */
-    public void setMaxErrors(int maxErrors) {
-        this.maxErrors = maxErrors;
-    }
-
-    /**
-     * Gets health check frequency. Defines how often in milliseconds an attempt to restore connection to disconnected
-     * receiver hubs is performed and how often connected receiver hubs will be checked for necessity to send a ping
-     * request using {@link #getReadTimeout()} property.
-     * <p>
-     * Defaults to {@link #DFLT_HEALTH_CHECK_FREQ}.
-     *
-     * @return Health check frequency.
-     */
-    public long getHealthCheckFrequency() {
-        return healthCheckFreq;
-    }
-
-    /**
-     * Sets health check frequency. See {@link #getHealthCheckFrequency()} for more information.
-     *
-     * @param healthCheckFreq Health check frequency.
-     */
-    public void setHealthCheckFrequency(long healthCheckFreq) {
-        this.healthCheckFreq = healthCheckFreq;
-    }
-
-    /**
-     * Gets system request timeout. Sender hub processor performs two types of system requests: handshake and ping.
-     * Handshake request contains information required by receiver hub and is only sent when network connection
-     * is established. Ping request just checks that receiver hub is reachable and responds when there was no
-     * reads from it for more than {@link #getReadTimeout()}.
-     * <p>
-     * In case any of these two requests was sent to receiver hub and there is no response for too long, it
-     * indicates a problem with either network connectivity or receiver hub itself. Thus, when the given timeout is
-     * exceeded, connection to receiver hub is closed.
-     * <p>
-     * Defaults to {@link #DFLT_SYS_REQ_TIMEOUT}.
-     *
-     * @return System request timeout.
-     */
-    public long getSystemRequestTimeout() {
-        return sysReqTimeout;
-    }
-
-    /**
-     * Sets system request timeout. See {@link #getSystemRequestTimeout()} for more information.
-     *
-     * @param sysReqTimeout System request timeout.
-     */
-    public void setSystemRequestTimeout(long sysReqTimeout) {
-        this.sysReqTimeout = sysReqTimeout;
-    }
-
-    /**
-     * Gets read timeout. When difference between current time and the time when last read operation on particular
-     * remote receiver hub occurred is greater than this timeout (in milliseconds), ping request will be sent to
-     * this receiver hub.
-     * <p>
-     * Defaults to {@link #DFLT_READ_TIMEOUT}.
-     *
-     * @return Read timeout.
-     */
-    public long getReadTimeout() {
-        return readTimeout;
-    }
-
-    /**
-     * Sets read timeout. See {@link #getReadTimeout()} for more information.
-     *
-     * @param readTimeout Read timeout.
-     */
-    public void setReadTimeout(long readTimeout) {
-        this.readTimeout = readTimeout;
-    }
-
-    /**
-     * Gets maximum wait queue size. Defines maximum amount of entries which are read from store but have not been
-     * acknowledged yet.
-     * <p>
-     * Defaults to {@link #DFLT_MAX_QUEUE_SIZE}.
-     *
-     * @return Maximum wait queue size.
-     */
-    public int getMaxQueueSize() {
-        return maxQueueSize;
-    }
-
-    /**
-     * Sets maximum wait queue size. See {@link #getMaxQueueSize()} for more information.
-     *
-     * @param maxQueueSize Maximum wait queue size.
-     */
-    public void setMaxQueueSize(int maxQueueSize) {
-        this.maxQueueSize = maxQueueSize;
-    }
-
-    /**
-     * Gets reconnect-on-failure timeout. This values defines timeout in milliseconds after which connection to
-     * remote receiver hub can be re-established in case it was previously disconnected due to a failure.
-     * <p>
-     * Defaults to {@link #DFLT_RECONNECT_ON_FAILURE_TIMEOUT}.
-     *
-     * @return Reconnect-on-failure timeout.
-     */
-    public long getReconnectOnFailureTimeout() {
-        return reconnOnFailureTimeout;
-    }
-
-    /**
-     * Sets reconnect-on-failure timeout. See {@link #getReconnectOnFailureTimeout()} for more information.
-     *
-     * @param reconnectOnFailureTimeout Reconnect-on-failure timeout.
-     */
-    public void setReconnectOnFailureTimeout(long reconnectOnFailureTimeout) {
-        this.reconnOnFailureTimeout = reconnectOnFailureTimeout;
-    }
-
-    /**
-     * Gets cache names this sender hub works with. All sender hubs working with concrete cache must have this
-     * property equal. E.g., in case one sender hub works with caches A and B, then another sender hub cannot work
-     * with caches B and C. Instead, both sender hubs must work with either {A, B}, {B, C} or even {A, B, C} caches.
-     * However, it is possible for the first sender hub work with caches {A, B} and for the second sender hub to work
-     * with caches {C, D}.
-     *
-     * @return Cache names this sender hub works with.
-     */
-    public String[] getCacheNames() {
-        return cacheNames;
-    }
-
-    /**
-     * Set cache names this sender hub works with. See {@link #getCacheNames()} for more information.
-     *
-     * @param cacheNames Cache names this sender hub works with.
-     */
-    @SuppressWarnings({"ZeroLengthArrayAllocation"})
-    public void setCacheNames(@Nullable String... cacheNames) {
-        this.cacheNames = cacheNames != null ? cacheNames : new String[0];
-
-        // Mask cache names.
-        for (int i = 0; i < this.cacheNames.length; i++)
-            this.cacheNames[i] = CU.mask(this.cacheNames[i]);
-
-        Arrays.sort(this.cacheNames);
-    }
-
-    /**
-     * Gets store. All incoming sender cache batches will be saved in this store before being sent to receiver hubs.
-     * Once acknowledge for particular batch is received from all destination receiver hubs, this batch will be
-     * removed from store.
-     * <p>
-     * If set to {@code null} then {@link GridDrSenderHubInMemoryStore} will be used as a default.
-     *
-     * @return Store.
-     */
-    public GridDrSenderHubStore getStore() {
-        return store;
-    }
-
-    /**
-     * Sets store. See {@link #getStore()} for more information.
-     *
-     * @param store Store.
-     */
-    public void setStore(GridDrSenderHubStore store) {
-        this.store = store;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(GridDrSenderHubConfiguration.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConnectionConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConnectionConfiguration.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConnectionConfiguration.java
deleted file mode 100644
index 1dac053..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubConnectionConfiguration.java
+++ /dev/null
@@ -1,194 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender;
-
-import org.gridgain.grid.dr.hub.receiver.*;
-import org.gridgain.grid.util.typedef.internal.*;
-
-import static org.gridgain.grid.dr.hub.receiver.GridDrReceiverHubLoadBalancingMode.*;
-
-/**
- * Data center replication sender hub connection configuration.
- */
-public class GridDrSenderHubConnectionConfiguration {
-    /** Default receiver hub load balancing policy. */
-    public static final GridDrReceiverHubLoadBalancingMode DFLT_RCV_HUB_LOAD_BALANCING_MODE = DR_RANDOM;
-
-    /** Default await acknowledge flag. */
-    public static final boolean DFLT_AWAIT_ACK = true;
-
-    /** Data center ID.*/
-    private byte dataCenterId;
-
-    /** Addresses. */
-    private String[] rcvHubAddrs;
-
-    /** Local host. */
-    private String locOutboundHost;
-
-    /** Receiver hub load balancing policy. */
-    private GridDrReceiverHubLoadBalancingMode rcvHubLoadBalancingMode = DFLT_RCV_HUB_LOAD_BALANCING_MODE;
-
-    /** Ignored data center IDs. */
-    private byte[] ignoreDataCenterIds;
-
-    /** Await acknowledge flag. */
-    private boolean awaitAck = DFLT_AWAIT_ACK;
-
-    /**
-     * Constructor.
-     */
-    public GridDrSenderHubConnectionConfiguration() {
-        // No-op.
-    }
-
-    /**
-     * Copying constructor.
-     *
-     * @param cfg Configuration to copy.
-     */
-    public GridDrSenderHubConnectionConfiguration(GridDrSenderHubConnectionConfiguration cfg) {
-        rcvHubAddrs = cfg.getReceiverHubAddresses();
-        dataCenterId = cfg.getDataCenterId();
-        ignoreDataCenterIds = cfg.getIgnoredDataCenterIds();
-        locOutboundHost = cfg.getLocalOutboundHost();
-        rcvHubLoadBalancingMode = cfg.getReceiverHubLoadBalancingMode();
-        awaitAck = cfg.isAwaitAcknowledge();
-    }
-
-    /**
-     * Gets ID of remote data center.
-     *
-     * @return ID of remote data center.
-     */
-    public byte getDataCenterId() {
-        return dataCenterId;
-    }
-
-    /**
-     * Sets ID of remote data center. See {@link #getDataCenterId()} for more information.
-     *
-     * @param dataCenterId ID of remote data center.
-     */
-    public void setDataCenterId(byte dataCenterId) {
-        this.dataCenterId = dataCenterId;
-    }
-
-    /**
-     * Gets addresses of remote receiver hubs.
-     *
-     * @return Addresses of remote receiver hubs.
-     */
-    public String[] getReceiverHubAddresses() {
-        return rcvHubAddrs;
-    }
-
-    /**
-     * Sets addresses of remote receiver hubs. See {@link #getReceiverHubAddresses()} for more information.
-     *
-     * @param rcvHubAddrs Addresses of remote receiver hubs.
-     */
-    public void setReceiverHubAddresses(String... rcvHubAddrs) {
-        this.rcvHubAddrs = rcvHubAddrs;
-    }
-
-    /**
-     * Gets local network interface name form with remote data center is reachable.
-     * <p>
-     * By default is set to {@code null} meaning that sender hub will be bound to the same interface as the grid itself
-     * (see {@link org.apache.ignite.configuration.IgniteConfiguration#getLocalHost()})
-     *
-     * @return Local network interface name form with remote data center is reachable.
-     */
-    public String getLocalOutboundHost() {
-        return locOutboundHost;
-    }
-
-    /**
-     * Sets local network interface name form with remote data center is reachable. See {@link #getLocalOutboundHost()}
-     * for more information.
-     *
-     * @param locOutboundHost Local network interface name form with remote data center is reachable.
-     */
-    public void setLocalOutboundHost(String locOutboundHost) {
-        this.locOutboundHost = locOutboundHost;
-    }
-
-    /**
-     * Gets remote receiver hub load balancing policy. This policy provides balancing mechanism in case remote data
-     * center has several receiver hubs.
-     * <p>
-     * Defaults to {@link #DFLT_RCV_HUB_LOAD_BALANCING_MODE}.
-     *
-     * @return Remote receiver hub load balancing policy.
-     */
-    public GridDrReceiverHubLoadBalancingMode getReceiverHubLoadBalancingMode() {
-        return rcvHubLoadBalancingMode;
-    }
-
-    /**
-     * Sets remote receiver hub load balancing policy. See {@link #getReceiverHubLoadBalancingMode()}
-     * for more information.
-     *
-     * @param rcvHubLoadBalancingMode Remote receiver hub load balancing policy.
-     */
-    public void setReceiverHubLoadBalancingMode(GridDrReceiverHubLoadBalancingMode rcvHubLoadBalancingMode) {
-        this.rcvHubLoadBalancingMode = rcvHubLoadBalancingMode;
-    }
-
-    /**
-     * Gets IDs of data centers updates from which will not be replicated to this remote data center.
-     * Use this parameter to avoid cycles in replication. For example, if you have setup your replication
-     * in a way that {@code A} replicates to {@code B}, {@code B} replicates to {@code C}, and {@code C}
-     * replicates back to {@code A}, then on {@code C} you should specify that updates from {@code A}
-     * should be ignored to avoid a cycle.
-     *
-     * @return Ignored data center IDs.
-     */
-    public byte[] getIgnoredDataCenterIds() {
-        return ignoreDataCenterIds;
-    }
-
-    /**
-     * Sets ignored data center IDs. See {@link #getIgnoredDataCenterIds()}
-     *
-     * @param ignoreDataCenterIds Ignored data center IDs.
-     */
-    public void setIgnoredDataCenterIds(byte... ignoreDataCenterIds) {
-        this.ignoreDataCenterIds = ignoreDataCenterIds;
-    }
-
-    /**
-     * Gets await acknowledge flag. When set to {@code true} sender hub will await acknowledge for each replication
-     * batch sent to a receiver hub thus ensuring that data is stored in remote topology. If set to {@code false},
-     * sender hub will not wait for that acknowledge. This will increase throughput at a cost of reliability.
-     * <p>
-     * Defaults to {@link #DFLT_AWAIT_ACK}.
-     *
-     * @return Await acknowledge flag.
-     */
-    public boolean isAwaitAcknowledge() {
-        return awaitAck;
-    }
-
-    /**
-     * Sets await acknowledge flag. See {@link #isAwaitAcknowledge()}
-     *
-     * @param awaitAck Await acknowledge flag.
-     */
-    public void setAwaitAcknowledge(boolean awaitAck) {
-        this.awaitAck = awaitAck;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(GridDrSenderHubConnectionConfiguration.class, this);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubInMetrics.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubInMetrics.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubInMetrics.java
deleted file mode 100644
index 5498d7d..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubInMetrics.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender;
-
-/**
- * Data center replication sender hub metrics for incoming data, i.e. data transferred from sender caches to
- * sender hub.
- */
-public interface GridDrSenderHubInMetrics {
-    /**
-     * Gets amount of batches received from sender caches.
-     *
-     * @return Amount of batches received from sender caches.
-     */
-    public int batchesReceived();
-
-    /**
-     * Gets amount of cache entries received from sender caches.
-     *
-     * @return Amount of cache entries received from sender caches.
-     */
-    public long entriesReceived();
-
-    /**
-     * Gets amount of bytes received from sender caches.
-     *
-     * @return Amount of bytes received from sender caches.
-     */
-    public long bytesReceived();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubLoadBalancingMode.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubLoadBalancingMode.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubLoadBalancingMode.java
deleted file mode 100644
index 5fff801..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubLoadBalancingMode.java
+++ /dev/null
@@ -1,41 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender;
-
-import org.jetbrains.annotations.*;
-
-/**
- * Data center replication sender hub load balancing mode. Determines to which sender hub next batch will be sent
- * from the sender cache.
- */
-public enum GridDrSenderHubLoadBalancingMode {
-    /**
-     * Balance sender hubs in random fashion.
-     */
-    DR_RANDOM,
-
-    /**
-     * Balance sender hubs in round-robin fashion.
-     */
-    DR_ROUND_ROBIN;
-
-    /** Enumerated values. */
-    private static final GridDrSenderHubLoadBalancingMode[] VALS = values();
-
-    /**
-     * Efficiently gets enumerated value from its ordinal.
-     *
-     * @param ord Ordinal value.
-     * @return Enumerated value or {@code null} if ordinal out of range.
-     */
-    @Nullable public static GridDrSenderHubLoadBalancingMode fromOrdinal(int ord) {
-        return ord >= 0 && ord < VALS.length ? VALS[ord] : null;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubMBean.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubMBean.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubMBean.java
deleted file mode 100644
index 2e551a7..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubMBean.java
+++ /dev/null
@@ -1,110 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender;
-
-import org.apache.ignite.mbean.*;
-
-/**
- * This interface defines JMX view on data center replication sender hub.
- */
-@IgniteMBeanDescription("MBean that provides access to sender hub descriptor.")
-public interface GridDrSenderHubMBean {
-    /**
-     * Gets metrics (statistics) for this sender hub.
-     *
-     * @return Sender hub metrics.
-     */
-    @IgniteMBeanDescription("Formatted sender hub metrics.")
-    public String metricsFormatted();
-
-    /**
-     * Gets maximum wait queue size. When there are too many replication requests coming to sender hub and it
-     * cannot process them at the same speed, it is necessary to restrict maximum waiting requests size in
-     * order to avoid out-of-memory issues.
-     *
-     * @return Maximum wait queue size.
-     */
-    @IgniteMBeanDescription("Maximum size of wait queue.")
-    public int getMaxQueueSize();
-
-    /**
-     * Gets health check frequency in milliseconds. This frequency shows how often disconnected nodes will try
-     * reconnect and how often connected nodes will be checked for necessity to send a ping request.
-     *
-     * @return Ping frequency.
-     */
-    @IgniteMBeanDescription("Health check frequency in milliseconds.")
-    public long getHealthCheckFrequency();
-
-    /**
-     * Gets system request timeout. Replication processor performs two types of system requests: handshake and ping.
-     * Handshake request contains information required by receiving side and is only sent when network connection
-     * is established. Ping request just checks that receiving side is reachable and responds when there was no
-     * reads from it for too long.
-     * In case any of these two requests was sent to receiving hub and there is no response for too long, it
-     * indicates a problem with either connectivity or receiving hub itself. Thus, when the given timeout is
-     * exceeded, remote sender hub node is disconnected.
-     *
-     * @return System request timeout in milliseconds.
-     */
-    @IgniteMBeanDescription("System request timeout.")
-    public long getSystemRequestTimeout();
-
-    /**
-     * Gets read timeout in milliseconds. In case difference between current time and the time when last read operation
-     * occurred is greater than this timeout, ping request will be sent to remote sender hub.
-     *
-     * @return Read timeout in milliseconds.
-     */
-    @IgniteMBeanDescription("Read timeout in milliseconds.")
-    public long getReadTimeout();
-
-    /**
-     * Gets maximum failed connection attempts.
-     * When this limit is reached, remote data center sender hub node gets disconnected.
-     *
-     * @return Maximum failed connect attempts.
-     */
-    @IgniteMBeanDescription("Maximum failed connection attempts.")
-    public int getMaxFailedConnectAttempts();
-
-    /**
-     * Maximum amount of errors received from remote data center sender hub node.
-     * When this limit is reached, remote data center sender hub node gets disconnected.
-     *
-     * @return Maximum errors.
-     */
-    @IgniteMBeanDescription("Maximum amount of errors received from the remote data center.")
-    public int getMaxErrors();
-
-    /**
-     * Timeout after which node can be reconnected in case it was previously disconnected due to a failure.
-     *
-     * @return Reconnect-on-failure timeout.
-     */
-    @IgniteMBeanDescription("Node reconnection timeout after failure.")
-    public long getReconnectOnFailureTimeout();
-
-    /**
-     * Gets cache names this sender hub works with.
-     *
-     * @return Cache names this sender hub works with.
-     */
-    @IgniteMBeanDescription("Cache names.")
-    public String getCacheNames();
-
-    /**
-     * Gets formatted remote data centers configuration info.
-     *
-     * @return Formatted remote data centers configuration info.
-     */
-    @IgniteMBeanDescription("Formatted remote data centers configuration info.")
-    public String remoteDataCentersFormatted();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubOutMetrics.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubOutMetrics.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubOutMetrics.java
deleted file mode 100644
index c15afed..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/GridDrSenderHubOutMetrics.java
+++ /dev/null
@@ -1,66 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender;
-
-/**
- * Data center replication sender hub metrics for outgoing data, i.e. data transferred from sender hub to
- * remote receiver hubs.
- */
-public interface GridDrSenderHubOutMetrics {
-    /**
-     * Gets amount of batches sent to receiver hubs.
-     *
-     * @return Amount of batches sent to receiver hubs.
-     */
-    public int batchesSent();
-
-    /**
-     * Gets amount of bytes sent to receiver hubs.
-     *
-     * @return Amount of bytes sent to receiver hubs.
-     */
-    public long entriesSent();
-
-    /**
-     * Gets amount of bytes sent to receiver hubs.
-     *
-     * @return Amount of bytes sent to receiver hubs.
-     */
-    public long bytesSent();
-
-    /**
-     * Gets amount of sent batches with received acknowledgement from receiver hubs.
-     *
-     * @return Amount of sent batches with received acknowledgement from receiver hubs.
-     */
-    public int batchesAcked();
-
-    /**
-     * Gets amount of sent entries with received acknowledgement from receiver hubs.
-     *
-     * @return Amount of sent entries with received acknowledgement from receiver hubs.
-     */
-    public long entriesAcked();
-
-    /**
-     * Gets amount of sent bytes with received acknowledgement from receiver hubs.
-     *
-     * @return Amount of sent bytes with received acknowledgement from receiver hubs.
-     */
-    public long bytesAcked();
-
-    /**
-     * Gets average time in milliseconds between sending batch for the first time and receiving acknowledgement for it.
-     *
-     * @return Average time in milliseconds between sending batch for the first time and receiving acknowledgement
-     *     for it.
-     */
-    public double averageBatchAckTime();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/package.html b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/package.html
deleted file mode 100644
index 876346d..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/package.html
+++ /dev/null
@@ -1,17 +0,0 @@
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!--
-    @html.file.header
-    _________        _____ __________________        _____
-    __  ____/___________(_)______  /__  ____/______ ____(_)_______
-    _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
-    / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
-    \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
--->
-<html>
-<body>
-    <img alt="icon" class="javadocimg" src="{@docRoot}/img/cube.gif"/>
-    Data center replication-related interfaces and classes for sender hubs.
-    <p>
-    @html.java.package
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStore.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStore.java
deleted file mode 100644
index 6081a9e..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStore.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender.store;
-
-import org.gridgain.grid.*;
-import org.gridgain.grid.dr.hub.sender.store.fs.*;
-import org.gridgain.grid.dr.hub.sender.store.memory.*;
-
-/**
- * Data center replication sender hub store. Persists batches received from data nodes until they are successfully
- * sent to receiver hub.
- * <p>
- * Gridgain provides the following {@code GridDrStore} implementations:
- * <ul>
- * <li>{@link GridDrSenderHubInMemoryStore}</li>
- * <li>{@link GridDrSenderHubFsStore}</li>
- * </ul>
- */
-public interface GridDrSenderHubStore {
-    /**
-     * Store data.
-     *
-     * @param dataCenterIds Target data center ids.
-     * @param data Data center replication store entry.
-     * @throws GridException In case of failure.
-     * @throws GridDrSenderHubStoreOverflowException If overflowed.
-     */
-    public void store(byte[] dataCenterIds, byte[] data) throws GridException, GridDrSenderHubStoreOverflowException;
-
-    /**
-     * Gets cursor for the given data center ID.
-     *
-     * @param dataCenterId Data center ID.
-     * @return Cursor over stored entries which belongs to that data center ID.
-     * @throws GridException If failed.
-     */
-    public GridDrSenderHubStoreCursor cursor(byte dataCenterId) throws GridException;
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCorruptedException.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCorruptedException.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCorruptedException.java
deleted file mode 100644
index 7319c0c..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCorruptedException.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender.store;
-
-import org.gridgain.grid.*;
-
-/**
- * Exception thrown in case data center replication sender hub store was corrupted.
- */
-public class GridDrSenderHubStoreCorruptedException extends GridException {
-    /** */
-    private static final long serialVersionUID = 0L;
-
-    /**
-     * Constructor.
-     *
-     * @param msg Message.
-     */
-    public GridDrSenderHubStoreCorruptedException(String msg) {
-        super(msg);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCursor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCursor.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCursor.java
deleted file mode 100644
index 7885ef8..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreCursor.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender.store;
-
-import org.gridgain.grid.*;
-import org.jetbrains.annotations.*;
-
-/**
- * Data center replication sender hub store cursor.
- */
-public interface GridDrSenderHubStoreCursor extends AutoCloseable {
-    /**
-     * Get next entry from that cursor.
-     *
-     * @return Next entry from cursor or {@code null} if none.
-     * @throws GridException If failed.
-     * @throws GridDrSenderHubStoreCorruptedException If store was corrupted.
-     */
-    @Nullable public GridDrSenderHubStoreEntry next() throws GridException, GridDrSenderHubStoreCorruptedException;
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreEntry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreEntry.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreEntry.java
deleted file mode 100644
index 8fedda5..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreEntry.java
+++ /dev/null
@@ -1,25 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender.store;
-
-/**
- * Data center replication sender hub store entry.
- */
-public interface GridDrSenderHubStoreEntry {
-    /**
-     * @return Prepared external request.
-     */
-    public byte[] data();
-
-    /**
-     * Acknowledge.
-     */
-    public void acknowledge();
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowException.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowException.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowException.java
deleted file mode 100644
index 8dd90ec..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowException.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender.store;
-
-import org.gridgain.grid.*;
-
-/**
- * Exception thrown when data center replication sender hub store cannot persist more entries.
- */
-public class GridDrSenderHubStoreOverflowException extends GridException {
-    /** */
-    private static final long serialVersionUID = 0L;
-
-    /**
-     * Constructor.
-     */
-    public GridDrSenderHubStoreOverflowException() {
-        super("No more data can be stored.");
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b7a63383/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowMode.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowMode.java b/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowMode.java
deleted file mode 100644
index ebb8ccd..0000000
--- a/modules/core/src/main/java/org/gridgain/grid/dr/hub/sender/store/GridDrSenderHubStoreOverflowMode.java
+++ /dev/null
@@ -1,36 +0,0 @@
-/* @java.file.header */
-
-/*  _________        _____ __________________        _____
- *  __  ____/___________(_)______  /__  ____/______ ____(_)_______
- *  _  / __  __  ___/__  / _  __  / _  / __  _  __ `/__  / __  __ \
- *  / /_/ /  _  /    _  /  / /_/ /  / /_/ /  / /_/ / _  /  _  / / /
- *  \____/   /_/     /_/   \_,__/   \____/   \__,_/  /_/   /_/ /_/
- */
-
-package org.gridgain.grid.dr.hub.sender.store;
-
-import org.jetbrains.annotations.*;
-
-/**
- * Data center replication sender hub store overflow mode.
- */
-public enum GridDrSenderHubStoreOverflowMode {
-    /** Removes oldest entries. */
-    REMOVE_OLDEST,
-
-    /** Stops accepting data in store. */
-    STOP;
-
-    /** Enumerated values. */
-    private static final GridDrSenderHubStoreOverflowMode[] VALS = values();
-
-    /**
-     * Efficiently gets enumerated value from its ordinal.
-     *
-     * @param ord Ordinal value.
-     * @return Enumerated value or {@code null} if ordinal out of range.
-     */
-    @Nullable public static GridDrSenderHubStoreOverflowMode fromOrdinal(int ord) {
-        return ord >= 0 && ord < VALS.length ? VALS[ord] : null;
-    }
-}


Mime
View raw message