Package net.tomp2p.rpc

Examples of net.tomp2p.rpc.ObjectDataReply

374
375
376
377
378
379
380
381
382
383
384
    l.log(TYPE_CREATED,
        String.format("New Peer created: %s", pp.getPeer()), 10);
    this.p = pp.getPeer();

    /* wait for incoming messages and fire them */
    p.setObjectDataReply(new ObjectDataReply() {
      public Object reply(PeerAddress sender, Object request)
          throws Exception {
        if (request instanceof String) {
          String from = toHex(sender.toByteArray());
          String message = (String) request;
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
        /**
         * @param peer
         *            Set reply handler for peer.
         */
        private void setReplyHandler(final PeerDHT peer) {
            peer.peer().objectDataReply(new ObjectDataReply() {
                @Override
                public Object reply(final PeerAddress sender, final Object request) throws Exception {
                    if (request != null && request instanceof Number160) {
                        return friends.get((Number160) request);
                    } else {
View Full Code Here
25
26
27
28
29
30
31
32
33
34
35
      final Peer peer = new PeerBuilder(Number160.createHash("client")).ports(1235).start();
            List<PeerAddress> bootstrap = new ArrayList<PeerAddress>();
            bootstrap.add(new PeerAddress(Number160.createHash("master"), "localhost", 1234,1234));
            peer.bootstrap().bootstrapTo(bootstrap).start();

            peer.objectDataReply(new ObjectDataReply() {
                public Object reply(PeerAddress sender, Object request) throws Exception {
                    System.err.println("client received: " + request.toString());
                    return "pong";
                }
            });
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
  }

  private static void setupReplyHandler(PeerDHT[] peers) {
    for (final PeerDHT peer : peers) {
      peer.peer().objectDataReply(new ObjectDataReply() {
        @Override
        public Object reply(PeerAddress sender, Object request) throws Exception {
          System.err.println("I'm " + peer.peerID() + " and I just got the message [" + request
                  + "] from " + sender.peerId());
          return "world";
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
    try {
      Number160 peerId = Number160.createHash(TomP2PTests.SEED_ID_WAN_1);
          PeerMapConfiguration pmc = new PeerMapConfiguration(peerId).peerNoVerification();
          PeerMap pm = new PeerMap(pmc);
      peer = new PeerBuilder(peerId).ports(5000).peerMap(pm).start();
      peer.objectDataReply(new ObjectDataReply() {
        @Override
        public Object reply(PeerAddress sender, Object request) throws Exception {
          log.trace("received request: ", request.toString());
          return "pong";
        }
View Full Code Here
333
334
335
336
337
338
339
340
341
342
343
                peer2DHT = getDHTPeer("node_2", client2Port);

                final CountDownLatch countDownLatch = new CountDownLatch(1);

                final StringBuilder result = new StringBuilder();
                peer2DHT.peer().objectDataReply(new ObjectDataReply() {
                    @Override
                    public Object reply(PeerAddress sender, Object request) throws Exception {
                        countDownLatch.countDown();
                        result.append(String.valueOf(request));
                        return "pong";
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
       
        FuturePeerConnection pcMaster = master.createPeerConnection(slave.peerAddress());
        MyDirectDataRPC myDirectDataRPC = new MyDirectDataRPC(slave.peerBean(), slave.connectionBean());
        slave.directDataRPC(myDirectDataRPC);
       
        slave.objectDataReply(new ObjectDataReply() {
            @Override
            public Object reply(PeerAddress sender, Object request) throws Exception {
                return "yoo!";
            }
        });
       
        master.objectDataReply(new ObjectDataReply() {
            @Override
            public Object reply(PeerAddress sender, Object request) throws Exception {
                return "world!";
            }
        });
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
        ccc.pipelineFilter(createFilter());
           
            peer1 = new PeerBuilder(new Number160(RND)).ports(port1).channelClientConfiguration(ccc).channelServerConfiguration(csc).start();
            peer2 = new PeerBuilder(new Number160(RND)).ports(port2).start();
            //
            peer2.objectDataReply(new ObjectDataReply() {
                @Override
                public Object reply(final PeerAddress sender, final Object request) throws Exception {
                    return "world!";
                }
            });
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    final String requestString = "This is a test String";
    final String replyString = "SUCCESS HIT";
    final CountDownLatch cLatch = new CountDownLatch(3);

    unreachable.objectDataReply(new ObjectDataReply() {
      @Override
      public Object reply(PeerAddress sender, Object request) throws Exception {
        if (requestString.equals((String) request)) {
          System.err.println("received: " + (String) request);
          cLatch.countDown();
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
    System.err.println("testReverseConnection() start!");

    final String requestString = "This is a test String";
    final CountDownLatch cLatch = new CountDownLatch(1);

    unreachable.objectDataReply(new ObjectDataReply() {

      @Override
      public Object reply(PeerAddress sender, Object request) throws Exception {
        if (requestString.equals((String) request)) {
          System.err.println("received: " + (String) request);
View Full Code Here
TOP

Related Classes of net.tomp2p.rpc.ObjectDataReply

  • lupos.distributed.p2p.network.impl.TomP2P
  • net.tomp2p.dht.TestDHT
  • net.tomp2p.dht.TestSend
  • net.tomp2p.examples.ExampleDirectData
  • net.tomp2p.examples.ExamplePersistentConnection
  • net.tomp2p.examples.ExampleReconnect
  • net.tomp2p.examples.ExampleSend
  • net.tomp2p.examples.ExampleSimpleRecommondation$MyPeer
  • net.tomp2p.examples.SeedNodeForTesting
  • net.tomp2p.examples.TomP2PTests
    • Copyright © 2018 www.massapicom. 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.