commit | 02ac78251efc109fb76839f665e6e272a3725b73 | [log] [tgz] |
---|---|---|
author | Rishabh Patel <rishabh.mahendra.patel@gmail.com> | Sun Oct 16 12:11:52 2016 -0700 |
committer | Rishabh Patel <rishabh.mahendra.patel@gmail.com> | Sun Oct 16 12:11:52 2016 -0700 |
tree | a656340a1fa5e5dd4f371d57b6f19fa61b27bca5 | |
parent | 6bd922ed5c69f4d76b33bfce2b3484265d42e78c [diff] |
GOSSIP-29 Fix typo in GossipCore method name
diff --git a/src/main/java/org/apache/gossip/manager/GossipCore.java b/src/main/java/org/apache/gossip/manager/GossipCore.java index 367c47b..1871751 100644 --- a/src/main/java/org/apache/gossip/manager/GossipCore.java +++ b/src/main/java/org/apache/gossip/manager/GossipCore.java
@@ -102,7 +102,7 @@ } } - public void recieve(Base base){ + public void receive(Base base){ if (base instanceof Response){ if (base instanceof Trackable){ Trackable t = (Trackable) base;
diff --git a/src/main/java/org/apache/gossip/manager/PassiveGossipThread.java b/src/main/java/org/apache/gossip/manager/PassiveGossipThread.java index f2dce0b..2e1fd81 100644 --- a/src/main/java/org/apache/gossip/manager/PassiveGossipThread.java +++ b/src/main/java/org/apache/gossip/manager/PassiveGossipThread.java
@@ -86,7 +86,7 @@ debug(packet_length, json_bytes); try { Base activeGossipMessage = MAPPER.readValue(json_bytes, Base.class); - gossipCore.recieve(activeGossipMessage); + gossipCore.receive(activeGossipMessage); } catch (RuntimeException ex) {//TODO trap json exception LOGGER.error("Unable to process message", ex); }