# IGNITE-831 improve Custom message.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/76bc3710 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/76bc3710 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/76bc3710 Branch: refs/heads/ignite-831 Commit: 76bc3710a63652308150be4c066f26d080808818 Parents: 838bccb Author: sevdokimov <sevdoki...@gridgain.com> Authored: Tue Apr 28 15:48:34 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Tue Apr 28 15:48:34 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/events/DiscoveryCustomEvent.java | 10 ++++------ .../internal/managers/discovery/GridDiscoveryManager.java | 2 +- 2 files changed, 5 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/76bc3710/modules/core/src/main/java/org/apache/ignite/internal/events/DiscoveryCustomEvent.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/events/DiscoveryCustomEvent.java b/modules/core/src/main/java/org/apache/ignite/internal/events/DiscoveryCustomEvent.java index ee32692..5ffa895 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/events/DiscoveryCustomEvent.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/events/DiscoveryCustomEvent.java @@ -22,8 +22,6 @@ import org.apache.ignite.internal.managers.discovery.*; import org.apache.ignite.internal.processors.affinity.*; import org.apache.ignite.internal.util.typedef.internal.*; -import java.io.*; - /** * Custom event. */ @@ -34,7 +32,7 @@ public class DiscoveryCustomEvent extends DiscoveryEvent { /** * Built-in event type: custom event sent. * <br> - * Generated when someone invoke {@link GridDiscoveryManager#sendCustomEvent(Serializable)}. + * Generated when someone invoke {@link GridDiscoveryManager#sendCustomEvent(DiscoveryCustomMessage)}. * <p> * * @see DiscoveryCustomEvent @@ -42,7 +40,7 @@ public class DiscoveryCustomEvent extends DiscoveryEvent { public static final int EVT_DISCOVERY_CUSTOM_EVT = 18; /** */ - private Serializable data; + private DiscoveryCustomMessage data; /** Affinity topology version. */ private AffinityTopologyVersion affTopVer; @@ -57,14 +55,14 @@ public class DiscoveryCustomEvent extends DiscoveryEvent { /** * @return Data. */ - public Serializable data() { + public DiscoveryCustomMessage data() { return data; } /** * @param data New data. */ - public void data(Serializable data) { + public void data(DiscoveryCustomMessage data) { this.data = data; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/76bc3710/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java index 0df7d5f..8445c66 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java @@ -1774,7 +1774,7 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> { customEvt.type(type); customEvt.topologySnapshot(topVer.topologyVersion(), null); customEvt.affinityTopologyVersion(topVer); - customEvt.data(evt.get5()); + customEvt.data((DiscoveryCustomMessage)evt.get5()); ctx.event().record(customEvt); }
