Class RFC6587SyslogDeserializer

java.lang.Object

org.springframework.integration.syslog.inbound.RFC6587SyslogDeserializer

All Implemented Interfaces:

Deserializer<Map<String,?>>

public class RFC6587SyslogDeserializer
extends Object
implements Deserializer<Map<String,?>>

RFC5424/6587 Deserializer. Implemented as a Deserializer instead of a transformer because we may receive a mixture of octet counting and non-transparent framing - see RFC 6587.

Since:

4.1.1

Author:

Duncan McIntyre, Gary Russell, Uwez Khan

Constructor Summary

Constructors

Constructor	Description
RFC6587SyslogDeserializer()	Construct an instance using a ByteArrayLfSerializer for non-transparent frames.
RFC6587SyslogDeserializer(Deserializer<byte[]> delimitedDeserializer)	Construct an instance using the specified Deserializer for non-transparent frames.

Method Summary

Modifier and Type	Method	Description
Map<String,?>	deserialize(InputStream inputStream)
protected String	getCharset()
void	setMaxMessageSize(int maxMessageSize)	Set the maximum frame size accepted for an octet-counted frame.
void	setParser(RFC5424SyslogParser parser)

Methods inherited from class Object

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

Methods inherited from interface Deserializer

deserializeFromByteArray

Constructor Details

RFC6587SyslogDeserializer

public RFC6587SyslogDeserializer()

Construct an instance using a ByteArrayLfSerializer for non-transparent frames.

RFC6587SyslogDeserializer

public RFC6587SyslogDeserializer(Deserializer<byte[]> delimitedDeserializer)

Construct an instance using the specified Deserializer for non-transparent frames.

Parameters:

delimitedDeserializer - the Deserializer.

Method Details

setParser

public void setParser(RFC5424SyslogParser parser)

Parameters:

parser - the parser to set

setMaxMessageSize

public void setMaxMessageSize(int maxMessageSize)

Set the maximum frame size accepted for an octet-counted frame. A frame whose declared octet count exceeds this value is rejected with an IOException before any buffer is allocated, mirroring the maxMessageSize ceiling the non-transparent (LF-delimited) framing path already enforces. Defaults to the maxMessageSize of the delimited deserializer when it is an AbstractByteArraySerializer, otherwise AbstractByteArraySerializer.DEFAULT_MAX_MESSAGE_SIZE.

Parameters:

maxMessageSize - the maximum octet count to accept.

Since:

5.5.22

deserialize

public Map<String,?> deserialize(InputStream inputStream)
                          throws IOException

Specified by:

deserialize in interface Deserializer<Map<String,?>>

Throws:

IOException

getCharset

protected String getCharset()