me.moocar.logbackgelf

Class GelfChunkingOutputStream

java.lang.Object

java.io.OutputStream

me.moocar.logbackgelf.GelfChunkingOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class GelfChunkingOutputStream
extends OutputStream

An OutputStream that sends bytes as UDP packets to a [GELF](https://www.graylog.org/resources/gelf-2/) compatible remote server. Use flush() to signify the end of a message. If the total number of bytes in the message is less than maxPacketSize, they will be sent in one datagram. If more, the bytes will be broken up into GELF chunks and sent all at once when flush() is called. Note that this class is NOT thread safe. A sequential process should call flush() before another starts writing.

Constructor Summary

Constructors

Constructor and Description
GelfChunkingOutputStream(InetAddress address, int port, int maxPacketSize, MessageIdProvider messageIdProvider) Create a new GelfChunkingOutputStream

Method Summary

Modifier and Type	Method and Description
void	flush()
void	start()
void	write(int b)

Methods inherited from class java.io.OutputStream

close, write, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GelfChunkingOutputStream

public GelfChunkingOutputStream(InetAddress address,
                                int port,
                                int maxPacketSize,
                                MessageIdProvider messageIdProvider)

Create a new GelfChunkingOutputStream

Parameters:

address - The address of the remove server

port - The port of the remote server

maxPacketSize - The maximum number of bytes allowed before chunking begins

messageIdProvider - A object that generates totally unique (for this machine) 8-byte message IDs.

Method Detail

start

public void start()
           throws SocketException,
                  UnknownHostException

Throws:

SocketException

UnknownHostException

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException