Package org.apache.avro.ipc

Examples of org.apache.avro.ipc.SocketServer

102
103
104
105
106
107
108
            logger.debug(String.format("Binding avro service to %s:%s", listenAddr, listenPort));
        InetSocketAddress socketAddress = new InetSocketAddress(listenAddr, listenPort);
        SpecificResponder responder = new SpecificResponder(Cassandra.class, new CassandraServer());
       
        logger.info("Cassandra starting up...");
        server = new SocketServer(responder, socketAddress);
    }
View Full Code Here
108
109
110
111
112
113
114
115
  }
 
  public void addRpcPlugins(Requestor requestor){}
 
  public Server createServer(Responder testResponder) throws Exception{
    return server = new SocketServer(testResponder,
                              new InetSocketAddress(0));  
  }
View Full Code Here
319
320
321
322
323
324
325
326
327
328
329
330
331
332
    /**
     * Starts the RPC server.
     */
    public static void main(String[] args) throws Exception {
      SocketServer server = new SocketServer(
          new SpecificResponder(Simple.class, new TestImpl()),
          new InetSocketAddress(0));
      server.start();
      File portFile = new File(SERVER_PORTS_DIR, "java-port");
      FileWriter w = new FileWriter(portFile);
      w.write(Integer.toString(server.getPort()));
      w.close();
    }
View Full Code Here
106
107
108
109
110
111
112
113
  }
 
  public void addRpcPlugins(Requestor requestor){}
 
  public Server createServer(Responder testResponder) throws Exception{
    return server = new SocketServer(testResponder,
                              new InetSocketAddress(0));  
  }
View Full Code Here
336
337
338
339
340
341
342
343
344
345
346
347
348
349
    /**
     * Starts the RPC server.
     */
    public static void main(String[] args) throws Exception {
      SocketServer server = new SocketServer(
          new SpecificResponder(Simple.class, new TestImpl()),
          new InetSocketAddress(0));
      server.start();
      File portFile = new File(SERVER_PORTS_DIR, "java-port");
      FileWriter w = new FileWriter(portFile);
      w.write(Integer.toString(server.getPort()));
      w.close();
    }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
  protected static Simple proxy;

  @Before
  public void testStartServer() throws Exception {
    if (server != null) return;
    server = new SocketServer(new ReflectResponder(Simple.class, new TestImpl()),
                              new InetSocketAddress(0));
    server.start();
    client = new SocketTransceiver(new InetSocketAddress(server.getPort()));
    proxy = ReflectRequestor.getClient(Simple.class, client);
  }
View Full Code Here
65
66
67
68
69
70
71
72
73
74
  protected static Transceiver client;
  protected static Simple proxy;

  @Before
  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
101
102
103
104
105
106
107
108
109
110
  protected static GenericRequestor requestor;

  @Before
  public void testStartServer() throws Exception {
    if (server != null) return;
    server = new SocketServer(new TestResponder(), new InetSocketAddress(0));
    server.start();
    client = new SocketTransceiver(new InetSocketAddress(server.getPort()));
    requestor = new GenericRequestor(PROTOCOL, client);
  }
View Full Code Here
98
99
100
101
102
103
104
105
106
  protected static Transceiver client;
  protected static Requestor requestor;

  @Before
  public void testStartServer() throws Exception {
    server = new SocketServer(new TestResponder(), new InetSocketAddress(0));
    client = new SocketTransceiver(new InetSocketAddress(server.getPort()));
    requestor = new GenericRequestor(PROTOCOL, client);
  }
View Full Code Here
63
64
65
66
67
68
69
70
71
72
  protected static Transceiver client;
  protected static Simple proxy;

  @Before
  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
TOP

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

  • org.apache.avro.ipc.generic.GenericResponder
  • org.apache.avro.mapred.tether.TetheredProcess
  • org.apache.avro.mapred.tether.TetherTaskRunner
  • 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
    • 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.