T
- The kind of input stream readpublic class UdpSocketServer<T extends InputStream> extends AbstractSocketServer<T>
main(String[])
AbstractSocketServer.CommandLineArguments, AbstractSocketServer.ServerConfigurationFactory
logEventInput, logger, MAX_PORT
LOGGER
Constructor and Description |
---|
UdpSocketServer(int port,
LogEventBridge<T> logEventInput)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static UdpSocketServer<InputStream> |
createJsonSocketServer(int port)
Creates a socket server that reads JSON log events.
|
static UdpSocketServer<ObjectInputStream> |
createSerializedSocketServer(int port)
Creates a socket server that reads serialized log events.
|
static UdpSocketServer<ObjectInputStream> |
createSerializedSocketServer(int port,
List<String> allowedClasses)
Creates a socket server that reads serialized log events.
|
static UdpSocketServer<InputStream> |
createXmlSocketServer(int port)
Creates a socket server that reads XML log events.
|
static void |
main(String[] args)
Main startup for the server.
|
void |
run()
Accept incoming events and processes them.
|
void |
shutdown()
Shutdown the server.
|
awaitTermination, isActive, setActive, startNewThread
log
public UdpSocketServer(int port, LogEventBridge<T> logEventInput) throws IOException
port
- to listen on.logEventInput
- IOException
- If an error occurs.public static UdpSocketServer<InputStream> createJsonSocketServer(int port) throws IOException
port
- the port to listenIOException
- if an I/O error occurs when opening the socket.public static UdpSocketServer<ObjectInputStream> createSerializedSocketServer(int port) throws IOException
port
- the port to listenIOException
- if an I/O error occurs when opening the socket.public static UdpSocketServer<ObjectInputStream> createSerializedSocketServer(int port, List<String> allowedClasses) throws IOException
port
- the port to listenallowedClasses
- additional classes to allow for deserializationIOException
- if an I/O error occurs when opening the socket.public static UdpSocketServer<InputStream> createXmlSocketServer(int port) throws IOException
port
- the port to listenIOException
- if an I/O error occurs when opening the socket.public static void main(String[] args) throws Exception
args
- The command line arguments.Exception
- if an error occurs.public void run()
public void shutdown()
shutdown
in class AbstractSocketServer<T extends InputStream>
Copyright © 1999-2017. All Rights Reserved.
Apache Logging, Apache Log4j, Log4j, Apache, the Apache feather logo, the Apache Logging project logo, and the Apache Log4j logo are trademarks of The Apache Software Foundation.