org.bitcoinj.testing

Class TestWithNetworkConnections

java.lang.Object

org.bitcoinj.testing.TestWithNetworkConnections

Direct Known Subclasses:

TestWithPeerGroup

public class TestWithNetworkConnections
extends Object

Utility class that makes it easy to work with mock NetworkConnections.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestWithNetworkConnections.ClientType

Field Summary

Fields

Modifier and Type	Field and Description
protected Address	address
protected BlockChain	blockChain
protected BlockStore	blockStore
protected ECKey	key
protected BlockingQueue<InboundMessageQueuer>	newPeerWriteTargetQueue
static int	PEER_SERVERS
protected SocketAddress	socketAddress
protected NetworkParameters	unitTestParams
protected Wallet	wallet

Constructor Summary

Constructors

Constructor and Description
TestWithNetworkConnections(TestWithNetworkConnections.ClientType clientType)

Method Summary

Modifier and Type	Method and Description
protected void	closePeer(Peer peer)
protected InboundMessageQueuer	connect(Peer peer, VersionMessage versionMessage)
protected void	inbound(InboundMessageQueuer peerChannel, Message message)
protected Message	outbound(InboundMessageQueuer p1)
protected Peer	peerOf(InboundMessageQueuer ch)
protected void	pingAndWait(InboundMessageQueuer p)
void	setUp()
void	setUp(BlockStore blockStore)
protected void	startPeerServer(int i)
protected void	startPeerServers()
protected void	stopPeerServer(int i)
protected void	stopPeerServers()
void	tearDown()
protected Message	waitForOutbound(InboundMessageQueuer ch)

Methods inherited from class java.lang.Object

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

Field Detail

PEER_SERVERS

public static final int PEER_SERVERS

See Also:

Constant Field Values

unitTestParams

protected NetworkParameters unitTestParams

blockStore

protected BlockStore blockStore

blockChain

protected BlockChain blockChain

wallet

protected Wallet wallet

key

protected ECKey key

address

protected Address address

socketAddress

protected SocketAddress socketAddress

newPeerWriteTargetQueue

protected final BlockingQueue<InboundMessageQueuer> newPeerWriteTargetQueue

Constructor Detail

TestWithNetworkConnections

public TestWithNetworkConnections(TestWithNetworkConnections.ClientType clientType)

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

setUp

public void setUp(BlockStore blockStore)
           throws Exception

Throws:

Exception

startPeerServers

protected void startPeerServers()
                         throws IOException

Throws:

IOException

startPeerServer

protected void startPeerServer(int i)
                        throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

stopPeerServers

protected void stopPeerServers()

stopPeerServer

protected void stopPeerServer(int i)

connect

protected InboundMessageQueuer connect(Peer peer,
                                       VersionMessage versionMessage)
                                throws Exception

Throws:

Exception

closePeer

protected void closePeer(Peer peer)
                  throws Exception

Throws:

Exception

inbound

protected void inbound(InboundMessageQueuer peerChannel,
                       Message message)

pingAndWait

protected void pingAndWait(InboundMessageQueuer p)
                    throws Exception

Throws:

Exception

outbound

protected Message outbound(InboundMessageQueuer p1)
                    throws Exception

Throws:

Exception

waitForOutbound

protected Message waitForOutbound(InboundMessageQueuer ch)
                           throws InterruptedException

Throws:

InterruptedException

peerOf

protected Peer peerOf(InboundMessageQueuer ch)