ignite-137 review
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ca4870eb Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ca4870eb Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ca4870eb Branch: refs/heads/ignite-32 Commit: ca4870eb10064f2aaf478186843320a430d633cb Parents: 1800ff6 Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Tue Jan 27 16:56:57 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Tue Jan 27 16:56:57 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/internal/IgniteMessagingImpl.java | 6 ++++-- .../ignite/internal/processors/cache/IgniteCacheProxy.java | 3 ++- 2 files changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ca4870eb/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java index 3784799..a5d9106 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java @@ -31,7 +31,8 @@ import java.util.*; /** * {@link org.apache.ignite.IgniteMessaging} implementation. */ -public class IgniteMessagingImpl extends IgniteAsyncSupportAdapter<IgniteMessaging> implements IgniteMessaging, Externalizable { +public class IgniteMessagingImpl extends IgniteAsyncSupportAdapter<IgniteMessaging> + implements IgniteMessaging, Externalizable { /** */ private static final long serialVersionUID = 0L; @@ -158,7 +159,8 @@ public class IgniteMessagingImpl extends IgniteAsyncSupportAdapter<IgniteMessagi } /** {@inheritDoc} */ - @Override public UUID remoteListen(@Nullable Object topic, IgniteBiPredicate<UUID, ?> p) throws IgniteCheckedException { + @Override public UUID remoteListen(@Nullable Object topic, IgniteBiPredicate<UUID, ?> p) + throws IgniteCheckedException { A.notNull(p, "p"); guard(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ca4870eb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java index c9ff776..bb92b76 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java @@ -38,7 +38,8 @@ import java.util.concurrent.locks.*; /** * Cache proxy. */ -public class IgniteCacheProxy<K, V> extends IgniteAsyncSupportAdapter<IgniteCache<K, V>> implements IgniteCache<K, V>, Externalizable { +public class IgniteCacheProxy<K, V> extends IgniteAsyncSupportAdapter<IgniteCache<K, V>> + implements IgniteCache<K, V>, Externalizable { /** */ private static final long serialVersionUID = 0L;
