Package org.apache.avro.ipc

Examples of org.apache.avro.ipc.SocketTransceiver

68
69
70
71
72
73
74
75
76
77
78
      // start sub-process, connecting back to server
      this.subprocess = startSubprocess(job);
     
      // open client, connecting to sub-process
      this.clientTransceiver =
        new SocketTransceiver(new InetSocketAddress(outputService.inputPort()));
      this.inputClient = (InputProtocol)
        SpecificRequestor.getClient(InputProtocol.class, clientTransceiver);


    } catch (Exception t) {
View Full Code Here
52
53
54
55
56
57
58
59
  public void testStartServer() throws Exception {
    if (server != null) return;
    server = new SocketServer(new SpecificResponder(TestNamespace.class, new TestImpl()),
                              new InetSocketAddress(0));
    server.start();
    client = new SocketTransceiver(new InetSocketAddress(server.getPort()));
    proxy = SpecificRequestor.getClient(TestNamespace.class, client);
  }
View Full Code Here
110
111
112
113
114
115
116
    return server = new SocketServer(testResponder,
                              new InetSocketAddress(0));  
  }
 
  public Transceiver createTransceiver() throws Exception{
    return new SocketTransceiver(new InetSocketAddress(server.getPort()));
  }
View Full Code Here
305
306
307
308
309
310
311
312
313
314
315
      for (File f : SERVER_PORTS_DIR.listFiles()) {
        LineNumberReader reader = new LineNumberReader(new FileReader(f));
        int port = Integer.parseInt(reader.readLine());
        System.out.println("Validating java client to "+
            f.getName()+" - " + port);
        Transceiver client = new SocketTransceiver(
            new InetSocketAddress("localhost", port));
        proxy = (Simple)SpecificRequestor.getClient(Simple.class, client);
        TestProtocolSpecific proto = new TestProtocolSpecific();
        proto.testHello();
        proto.testEcho();
View Full Code Here
30
31
32
33
34
35
36
37
  @BeforeClass
  public void testStartServer() throws Exception {
    server = new SocketServer(new ReflectResponder(Simple.class, new TestImpl()),
                              new InetSocketAddress(0));
    client = new SocketTransceiver(new InetSocketAddress(server.getPort()));
    proxy = (Simple)ReflectRequestor.getClient(Simple.class, client);
  }
View Full Code Here
67
68
69
70
71
72
73
74
  @BeforeClass
  public void testStartServer() throws Exception {
    server = new SocketServer(new SpecificResponder(Simple.class, new TestImpl()),
                              new InetSocketAddress(0));
    client = new SocketTransceiver(new InetSocketAddress(server.getPort()));
    proxy = (Simple)SpecificRequestor.getClient(Simple.class, client);
  }
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
      for (File f : SERVER_PORTS_DIR.listFiles()) {
        LineNumberReader reader = new LineNumberReader(new FileReader(f));
        int port = Integer.parseInt(reader.readLine());
        System.out.println("Validating java client to "+
            f.getName()+" - " + port);
        Transceiver client = new SocketTransceiver(
            new InetSocketAddress("localhost", port));
        proxy = (Simple)SpecificRequestor.getClient(Simple.class, client);
        TestProtocolSpecific proto = new TestProtocolSpecific();
        proto.testHello();
        proto.testEcho();
View Full Code Here
110
111
112
113
114
115
116
    return server = new SocketServer(testResponder,
                              new InetSocketAddress(0));  
  }
 
  public Transceiver createTransceiver() throws Exception{
    return new SocketTransceiver(new InetSocketAddress(server.getPort()));
  }
View Full Code Here
306
307
308
309
310
311
312
313
314
315
316
      for (File f : SERVER_PORTS_DIR.listFiles()) {
        LineNumberReader reader = new LineNumberReader(new FileReader(f));
        int port = Integer.parseInt(reader.readLine());
        System.out.println("Validating java client to "+
            f.getName()+" - " + port);
        Transceiver client = new SocketTransceiver(
            new InetSocketAddress("localhost", port));
        proxy = (Simple)SpecificRequestor.getClient(Simple.class, client);
        TestProtocolSpecific proto = new TestProtocolSpecific();
        proto.testHello();
        proto.testEcho();
View Full Code Here
TOP

Related Classes of org.apache.avro.ipc.SocketTransceiver

  • org.apache.avro.mapred.tether.TetheredProcess
  • org.apache.avro.mapred.tether.TetherTask
  • org.apache.avro.TestNamespaceReflect
  • org.apache.avro.TestNamespaceSpecific
  • org.apache.avro.TestProtocolGeneric
  • org.apache.avro.TestProtocolGenericMeta
  • org.apache.avro.TestProtocolReflect
  • org.apache.avro.TestProtocolReflectMeta
  • org.apache.avro.TestProtocolSpecific
  • org.apache.avro.TestProtocolSpecific$InteropTest
    • 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.