public class PeerConnection extends Object
Constructor and Description |
---|
PeerConnection(PeerAddress destination,
ConnectionReservation connectionReservation,
ChannelCreator channelCreator,
int idleTCPMillis) |
Modifier and Type | Method and Description |
---|---|
void |
aquireSingleConnection()
Acquire one connection.
|
void |
close()
Closes and releases the connection from the reservation.
|
ChannelCreator |
getChannelCreator() |
PeerAddress |
getDestination() |
int |
getIdleTCPMillis() |
boolean |
isClosed() |
void |
releaseSingleConnection()
Releases one connection.
|
public PeerConnection(PeerAddress destination, ConnectionReservation connectionReservation, ChannelCreator channelCreator, int idleTCPMillis)
public void close()
public PeerAddress getDestination()
public ChannelCreator getChannelCreator()
public boolean isClosed()
public int getIdleTCPMillis()
public void aquireSingleConnection() throws InterruptedException
InterruptedException
public void releaseSingleConnection()
Copyright © 2013. All Rights Reserved.