//PipeWrapper pipeWrapper = new PipeWrapper("pipe#" + i, PipeWrapper.SENDER_PIPE, this.getReplicateToInstanceName(), nextPipe);
//this.waitForRendezvousConnection();
if (_pipelogger.isLoggable(Level.FINEST)) {
_pipelogger.finest("JxtaBiDiPipeWrapper: Attempting to establish a connection");
}
nextPipe.connect(this.netPeerGroup,
null,
this.pipeAdv,
//60000,
300000,
// register as a message listener the pipeWrapper