status-im/ethereumj-personal
2
0
Fork 0
mirror of https://github.com/status-im/ethereumj-personal.git synced 2025-02-27 03:00:28 +00:00
Code Issues Projects Releases Wiki Activity

EthereumListener update (addition)

Browse Source
This commit is contained in:
romanman 2014-08-06 20:35:58 +03:00
parent 7db4d0892f
commit 9f35988869
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ethereumj-core/src/main/java/org/ethereum/net/client/EthereumProtocolHandler.java
View File

@ -344,19 +344,19 @@ public class EthereumProtocolHandler extends ChannelInboundHandlerAdapter {
}
private void sendPing() {
msgQueue.sendMessage(PING_MESSAGE);
sendMsg(PING_MESSAGE);
}
private void sendPong() {
msgQueue.sendMessage(PONG_MESSAGE);
sendMsg(PONG_MESSAGE);
}
private void sendGetPeers() {
msgQueue.sendMessage(GET_PEERS_MESSAGE);
sendMsg(GET_PEERS_MESSAGE);
}
private void sendGetTransactions() {
msgQueue.sendMessage(GET_TRANSACTIONS_MESSAGE);
sendMsg(GET_TRANSACTIONS_MESSAGE);
}
private void sendGetChain() {
@ -370,6 +370,6 @@ public class EthereumProtocolHandler extends ChannelInboundHandlerAdapter {
byte[] hash = lastBlock.getHash();
GetChainMessage chainMessage =
new GetChainMessage( SystemProperties.CONFIG.maxBlocksAsk(), hash);
msgQueue.sendMessage(chainMessage);
sendMsg(chainMessage);
}
}