rdev/gossip-revisited
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

GOSSIP-29 Fix typo in GossipCore method name

Browse Source
This commit is contained in:
Rishabh Patel
2016-10-16 12:11:52 -07:00
parent 6bd922ed5c
commit 02ac78251e
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/apache/gossip/manager/GossipCore.java
View File

@ -102,7 +102,7 @@ public class GossipCore {
} }
} }
public void recieve(Base base){ public void receive(Base base){
if (base instanceof Response){ if (base instanceof Response){
if (base instanceof Trackable){ if (base instanceof Trackable){
Trackable t = (Trackable) base; Trackable t = (Trackable) base;

2
src/main/java/org/apache/gossip/manager/PassiveGossipThread.java
View File

@ -86,7 +86,7 @@ abstract public class PassiveGossipThread implements Runnable {
debug(packet_length, json_bytes); debug(packet_length, json_bytes);
try { try {
Base activeGossipMessage = MAPPER.readValue(json_bytes, Base.class); Base activeGossipMessage = MAPPER.readValue(json_bytes, Base.class);
gossipCore.recieve(activeGossipMessage); gossipCore.receive(activeGossipMessage);
} catch (RuntimeException ex) {//TODO trap json exception } catch (RuntimeException ex) {//TODO trap json exception
LOGGER.error("Unable to process message", ex); LOGGER.error("Unable to process message", ex);
} }