org.bitcoinj.testing

Class InboundMessageQueuer

java.lang.Object

org.bitcoinj.net.AbstractTimeoutHandler

org.bitcoinj.core.PeerSocketHandler

org.bitcoinj.testing.InboundMessageQueuer

All Implemented Interfaces:

StreamParser

public abstract class InboundMessageQueuer
extends PeerSocketHandler

An extension of PeerSocketHandler that keeps inbound messages in a queue for later processing

Field Summary

Fields

Modifier and Type	Field and Description
BlockingQueue<Message>	inboundMessages
BloomFilter	lastReceivedFilter
Map<Long,com.google.common.util.concurrent.SettableFuture<Void>>	mapPingFutures
Peer	peer

Fields inherited from class org.bitcoinj.core.PeerSocketHandler

peerAddress, writeTarget

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	InboundMessageQueuer(NetworkParameters params)

Method Summary

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

Methods inherited from class org.bitcoinj.core.PeerSocketHandler

close, getAddress, getMaxMessageSize, receiveBytes, sendMessage, setWriteTarget, timeoutOccurred

Methods inherited from class org.bitcoinj.net.AbstractTimeoutHandler

resetTimeout, setSocketTimeout, setTimeoutEnabled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.bitcoinj.net.StreamParser

connectionClosed, connectionOpened

Field Detail

inboundMessages

public final BlockingQueue<Message> inboundMessages

mapPingFutures

public final Map<Long,com.google.common.util.concurrent.SettableFuture<Void>> mapPingFutures

peer

public Peer peer

lastReceivedFilter

public BloomFilter lastReceivedFilter

Constructor Detail

InboundMessageQueuer

protected InboundMessageQueuer(NetworkParameters params)

Method Detail

nextMessage

public Message nextMessage()

nextMessageBlocking

public Message nextMessageBlocking()
                            throws InterruptedException

Throws:

InterruptedException

processMessage

protected void processMessage(Message m)
                       throws Exception

Description copied from class: PeerSocketHandler

Called every time a message is received from the network

Specified by:

processMessage in class PeerSocketHandler

Throws:

Exception