Repository: ignite Updated Branches: refs/heads/ignite-1093-2 d4a6f5aa3 -> 93497acf7
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/93497acf Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/93497acf Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/93497acf Branch: refs/heads/ignite-1093-2 Commit: 93497acf7fe9cf565b8606f828ff6eae0584c9de Parents: d4a6f5a Author: Anton Vinogradov <[email protected]> Authored: Sun Oct 11 13:49:00 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Sun Oct 11 13:49:00 2015 +0300 ---------------------------------------------------------------------- .../dht/preloader/GridDhtPartitionSupplier.java | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/93497acf/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java index 8206b93..d30f3c4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java @@ -696,13 +696,18 @@ class GridDhtPartitionSupplier { @Deprecated//Backward compatibility. To be removed in future. public void startOldListeners() { - if (!cctx.kernalContext().clientNode() && cctx.rebalanceEnabled()) { + try { + if (!cctx.kernalContext().clientNode() && cctx.rebalanceEnabled()) { - cctx.io().addHandler(cctx.cacheId(), GridDhtPartitionDemandMessage.class, new CI2<UUID, GridDhtPartitionDemandMessage>() { - @Override public void apply(UUID id, GridDhtPartitionDemandMessage m) { - processOldDemandMessage(m, id); - } - }); + cctx.io().addHandler(cctx.cacheId(), GridDhtPartitionDemandMessage.class, new CI2<UUID, GridDhtPartitionDemandMessage>() { + @Override public void apply(UUID id, GridDhtPartitionDemandMessage m) { + processOldDemandMessage(m, id); + } + }); + } + } + catch (Exception ex) { + U.error(log, "Unable to start backward compatibility rebalancing lixteners", ex); } }
