Package org.apache.avro.ipc

Examples of org.apache.avro.ipc.Server.start()

194
195
196
197
198
199
200
201
202
203
204
    Event event = EventBuilder.withBody("test event 1",
        Charset.forName("UTF8"));
    Server server = createServer(new MockAvroServer());

    server.start();
    sink.start();
    Assert.assertTrue(LifecycleController.waitForOneOf(sink,
        LifecycleState.START_OR_ERROR, 5000));

    Thread.sleep(500L); // let socket startup
View Full Code Here
224
225
226
227
228
229
230
231
232
233
234
      Assert.assertTrue("Must throw EventDeliveryException if disconnected",
          threwException);
    }

    server = createServer(new MockAvroServer());
    server.start();

    for (int i = 0; i < 5; i++) {
      Sink.Status status = sink.process();
      Assert.assertEquals(Sink.Status.READY, status);
    }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
  @Test
  public void testLifecycle() throws InterruptedException {
    Server server = createServer();

    server.start();

    sink.start();
    Assert.assertTrue(LifecycleController.waitForOneOf(sink,
        LifecycleState.START_OR_ERROR, 5000));
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
  public void testProcess() throws InterruptedException, EventDeliveryException {
    Event event = EventBuilder.withBody("test event 1".getBytes(),
        new HashMap<String, String>());
    Server server = createServer();

    server.start();

    sink.start();
    Assert.assertTrue(LifecycleController.waitForOneOf(sink,
        LifecycleState.START_OR_ERROR, 5000));
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
    Event event = EventBuilder.withBody("test event 1".getBytes(),
        new HashMap<String, String>());
    Server server = createServer();

    server.start();
    sink.start();
    Assert.assertTrue(LifecycleController.waitForOneOf(sink,
        LifecycleState.START_OR_ERROR, 5000));

    server.close();
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
      PollableSink.Status status = sink.process();
      Assert.assertEquals(PollableSink.Status.BACKOFF, status);
    }

    server = createServer();
    server.start();

    for (int i = 0; i < 5; i++) {
      PollableSink.Status status = sink.process();
      Assert.assertEquals(PollableSink.Status.READY, status);
    }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
  public static Server startServer(AvroSourceProtocol handler, int port) {
    Responder responder = new SpecificResponder(AvroSourceProtocol.class,
        handler);
    Server server = new NettyServer(responder,
        new InetSocketAddress(localhost, port));
    server.start();
    logger.info("Server started on hostname: {}, port: {}",
        new Object[] { localhost, Integer.toString(server.getPort()) });

    try {
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
            server = new NettyServer(responder, new InetSocketAddress(configuration.getHost(), configuration.getPort()));
        } else {
            throw new IllegalArgumentException("Unknown transport " + configuration.getTransport());
        }

        server.start();

        return server;
    }

    /**
 
View Full Code Here
19
20
21
22
23
24
25
26
27
28
29
    Protocol prot = new Protocol("c", "a.b");

    // start on port 9999
    InetSocketAddress addr = new InetSocketAddress(InetAddress.getLocalHost(), 9999);
    Server server = new SaslSocketServer(new SocketDoesntClose(prot), addr);
    server.start();
   
    // stop -- I would expect this to fully release the socket
    server.close();
   
    Thread.sleep(10000);
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
            server = new NettyServer(responder, new InetSocketAddress(configuration.getHost(), configuration.getPort()));
        } else {
            throw new IllegalArgumentException("Unknown transport " + configuration.getTransport());
        }

        server.start();

        return server;
    }

    /**
 
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.