Class AbstractKryoCodec
java.lang.Object
org.springframework.integration.codec.kryo.AbstractKryoCodec
- All Implemented Interfaces:
Codec
- Direct Known Subclasses:
PojoCodec
- Since:
- 4.2
- Author:
- David Turanski, Artem Bilan
-
Field Summary
Modifier and TypeFieldDescriptionprotected final com.esotericsoftware.kryo.util.Pool<com.esotericsoftware.kryo.Kryo>
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected abstract void
configureKryoInstance
(com.esotericsoftware.kryo.Kryo kryo) Subclasses implement this to configure the kryo instance.<T> T
Decode an object of a given type.<T> T
decode
(InputStream inputStream, Class<T> type) Decode an object of a given type.protected abstract <T> T
doDecode
(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<T> type) Subclasses implement this method to decode with Kryo.protected abstract void
doEncode
(com.esotericsoftware.kryo.Kryo kryo, Object object, com.esotericsoftware.kryo.io.Output output) Subclasses implement this method to encode with Kryo.byte[]
Encode an object to a byte array.void
encode
(Object object, OutputStream outputStream) Encode (encode) an object to an OutputStream.
-
Field Details
-
pool
protected final com.esotericsoftware.kryo.util.Pool<com.esotericsoftware.kryo.Kryo> pool
-
-
Constructor Details
-
AbstractKryoCodec
protected AbstractKryoCodec()
-
-
Method Details
-
encode
Description copied from interface:Codec
Encode (encode) an object to an OutputStream. -
decode
Description copied from interface:Codec
Decode an object of a given type.- Specified by:
decode
in interfaceCodec
- Type Parameters:
T
- the object's type- Parameters:
bytes
- the byte array containing the encoded objecttype
- the object's class- Returns:
- the object
- Throws:
IOException
- if the operation fails
-
decode
Description copied from interface:Codec
Decode an object of a given type. -
encode
Description copied from interface:Codec
Encode an object to a byte array.- Specified by:
encode
in interfaceCodec
- Parameters:
object
- the object to encode- Returns:
- the bytes
- Throws:
IOException
- if the operation fails
-
doEncode
protected abstract void doEncode(com.esotericsoftware.kryo.Kryo kryo, Object object, com.esotericsoftware.kryo.io.Output output) Subclasses implement this method to encode with Kryo.- Parameters:
kryo
- the Kryo instanceobject
- the object to encodeoutput
- the Kryo Output instance
-
doDecode
protected abstract <T> T doDecode(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<T> type) Subclasses implement this method to decode with Kryo.- Type Parameters:
T
- the type for decoded object- Parameters:
kryo
- the Kryo instanceinput
- the Kryo Input instancetype
- the class of the decoded object- Returns:
- the decoded object
-
configureKryoInstance
protected abstract void configureKryoInstance(com.esotericsoftware.kryo.Kryo kryo) Subclasses implement this to configure the kryo instance. This is invoked on each new Kryo instance when it is created.- Parameters:
kryo
- the Kryo instance
-