Package org.apache.avro.ipc.jetty
Class HttpServer
java.lang.Object
org.apache.avro.ipc.jetty.HttpServer
- All Implemented Interfaces:
org.apache.avro.ipc.Server
An HTTP-based RPC
Server
.-
Constructor Summary
ConstructorsConstructorDescriptionHttpServer
(org.apache.avro.ipc.Responder responder, int port) Constructs a server to run on the named port.HttpServer
(org.apache.avro.ipc.Responder responder, String bindAddress, int port) Constructs a server to run on the named port on the specified address.HttpServer
(org.apache.avro.ipc.Responder responder, InetSocketAddress addr) Constructs a server to run on the named port on the specified address.HttpServer
(org.apache.avro.ipc.Responder responder, org.eclipse.jetty.server.ConnectionFactory connectionFactory, String bindAddress, int port) Constructs a server to run with the given ConnectionFactory on the given address/port.HttpServer
(org.apache.avro.ipc.Responder responder, org.eclipse.jetty.server.Connector connector) Deprecated.- use the Constructors that take a ConnectionFactoryHttpServer
(org.apache.avro.ipc.ResponderServlet servlet, int port) Constructs a server to run on the named port.HttpServer
(org.apache.avro.ipc.ResponderServlet servlet, String bindAddress, int port) Constructs a server to run on the named port on the specified address.HttpServer
(org.apache.avro.ipc.ResponderServlet servlet, org.eclipse.jetty.server.ConnectionFactory connectionFactory, String bindAddress, int port) Constructs a server to run with the given ConnectionFactory on the given address/port.HttpServer
(org.apache.avro.ipc.ResponderServlet servlet, org.eclipse.jetty.server.Connector connector) Deprecated.- use the Constructors that take a ConnectionFactory -
Method Summary
Modifier and TypeMethodDescriptionvoid
addConnector
(org.eclipse.jetty.server.Connector connector) void
close()
int
getPort()
void
join()
void
start()
Start the server.
-
Constructor Details
-
HttpServer
Constructs a server to run on the named port.- Throws:
IOException
-
HttpServer
Constructs a server to run on the named port.- Throws:
IOException
-
HttpServer
public HttpServer(org.apache.avro.ipc.Responder responder, InetSocketAddress addr) throws IOException Constructs a server to run on the named port on the specified address.- Throws:
IOException
-
HttpServer
public HttpServer(org.apache.avro.ipc.Responder responder, String bindAddress, int port) throws IOException Constructs a server to run on the named port on the specified address.- Throws:
IOException
-
HttpServer
public HttpServer(org.apache.avro.ipc.ResponderServlet servlet, String bindAddress, int port) throws IOException Constructs a server to run on the named port on the specified address.- Throws:
IOException
-
HttpServer
public HttpServer(org.apache.avro.ipc.Responder responder, org.eclipse.jetty.server.ConnectionFactory connectionFactory, String bindAddress, int port) throws IOException Constructs a server to run with the given ConnectionFactory on the given address/port.- Throws:
IOException
-
HttpServer
public HttpServer(org.apache.avro.ipc.ResponderServlet servlet, org.eclipse.jetty.server.ConnectionFactory connectionFactory, String bindAddress, int port) throws IOException Constructs a server to run with the given ConnectionFactory on the given address/port.- Throws:
IOException
-
HttpServer
@Deprecated public HttpServer(org.apache.avro.ipc.ResponderServlet servlet, org.eclipse.jetty.server.Connector connector) throws IOException Deprecated.- use the Constructors that take a ConnectionFactoryConstructs a server to run with the given connector.- Throws:
IOException
-
HttpServer
@Deprecated public HttpServer(org.apache.avro.ipc.Responder responder, org.eclipse.jetty.server.Connector connector) throws IOException Deprecated.- use the Constructors that take a ConnectionFactoryConstructs a server to run with the given connector.- Throws:
IOException
-
-
Method Details
-
addConnector
public void addConnector(org.eclipse.jetty.server.Connector connector) -
getPort
public int getPort()- Specified by:
getPort
in interfaceorg.apache.avro.ipc.Server
-
close
public void close()- Specified by:
close
in interfaceorg.apache.avro.ipc.Server
-
start
public void start()Start the server.- Specified by:
start
in interfaceorg.apache.avro.ipc.Server
- Throws:
org.apache.avro.AvroRuntimeException
- if the underlying Jetty server throws any exception while starting.
-
join
- Specified by:
join
in interfaceorg.apache.avro.ipc.Server
- Throws:
InterruptedException
-