public abstract class InboundMessageQueuer extends PeerSocketHandler
PeerSocketHandler
that keeps inbound messages in a queue for later processingModifier and Type | Field and Description |
---|---|
BlockingQueue<Message> |
inboundMessages |
BloomFilter |
lastReceivedFilter |
Map<Long,SettableFuture<Void>> |
mapPingFutures |
Peer |
peer |
peerAddress, writeTarget
Modifier | Constructor and Description |
---|---|
protected |
InboundMessageQueuer(NetworkParameters params) |
Modifier and Type | Method and Description |
---|---|
Message |
nextMessage() |
Message |
nextMessageBlocking() |
protected void |
processMessage(Message m)
Called every time a message is received from the network
|
close, getAddress, getMaxMessageSize, receiveBytes, sendMessage, setWriteTarget, timeoutOccurred
resetTimeout, setSocketTimeout, setTimeoutEnabled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connectionClosed, connectionOpened
public final BlockingQueue<Message> inboundMessages
public final Map<Long,SettableFuture<Void>> mapPingFutures
public Peer peer
public BloomFilter lastReceivedFilter
protected InboundMessageQueuer(NetworkParameters params)
public Message nextMessage()
public Message nextMessageBlocking() throws InterruptedException
InterruptedException
protected void processMessage(Message m) throws Exception
PeerSocketHandler
processMessage
in class PeerSocketHandler
Exception
Copyright © 2014. All rights reserved.