Examples of restoreContentReferences()


Examples of net.tomp2p.message.Message.restoreContentReferences()

            recipientSocket = message.sender().createSocketTCP();
          }

          Buffer buffer = future.responseMessage().buffer(0);
          Message responseFromUnreachablePeer = RelayUtils.decodeMessage(buffer, recipientSocket, senderSocket, connectionBean().channelServer().channelServerConfiguration().signatureFactory());
          responseFromUnreachablePeer.restoreContentReferences();
          futureDone.done(responseFromUnreachablePeer);
        } else {
          futureDone.failed("Could not forward message over TCP channel");
        }
      }
View Full Code Here

Examples of net.tomp2p.message.Message.restoreContentReferences()

          sender = new InetSocketAddress(0);
        }
       
        Buffer requestBuffer = message.buffer(0);
        Message realMessage = RelayUtils.decodeRelayedMessage(requestBuffer, message.recipientSocket(), sender, signatureFactory());
        realMessage.restoreContentReferences();

        LOG.debug("Received message from relay peer: {}", realMessage);
       
        final Message envelope = createResponseMessage(message, Type.OK);
        final Responder responder = new Responder() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.