List of peerConnection() Examples

    fpc.addListener(new BaseFutureAdapter<FuturePeerConnection>() {
      // wait for the connection to the relay Peer
      @Override
      public void operationComplete(FuturePeerConnection future) throws Exception {
        if (fpc.isSuccess()) {
          final PeerConnection peerConnection = fpc.peerConnection();
          if (peerConnection != null) {
            // create the necessary messages
            final Message setUpMessage = createSetupMessage(relayPeerAddress, unreachablePeerAddress);


            // send the message to the relay so it forwards it to the unreachable peer

Examples of net.tomp2p.p2p.builder.PingBuilder.peerConnection()

            
            if(peerConnection!=null && nextDelay <= 0) {
                LOG.debug("sending heart beat to {}, {}", peerConnection.remotePeer(), 
                    (peerConnection.channelFuture() != null ? peerConnection.channelFuture().channel() : null));
                PingBuilder builder = pingBuilderFactory.create();
                BaseFuture baseFuture = builder.peerConnection(peerConnection).start();
                builder.notifyAutomaticFutures(baseFuture);
            } else {
              LOG.debug("Not sending heart beat to {}, {}", peerConnection.remotePeer(), 
                    (peerConnection.channelFuture() != null ? peerConnection.channelFuture().channel() : null));
            }

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.

Examples of peerConnection()

Examples of net.tomp2p.futures.FuturePeerConnection.peerConnection()

Examples of net.tomp2p.p2p.builder.PingBuilder.peerConnection()