public class ExtendedRiverUnmarshaller
extends RiverUnmarshaller
RiverUnmarshaller
that allows Infinispan StreamingMarshaller
instances to travel down the stack to potential externalizer implementations
that might need it, such as org.infinispan.commons.marshall.MarshalledValue.Externalizer
Modifier and Type | Field and Description |
---|---|
private StreamingMarshaller |
infinispanMarshaller |
private RiverCloseListener |
listener |
Modifier | Constructor and Description |
---|---|
protected |
ExtendedRiverUnmarshaller(RiverMarshallerFactory factory,
SerializableClassRegistry registry,
MarshallingConfiguration cfg) |
Modifier and Type | Method and Description |
---|---|
void |
finish() |
StreamingMarshaller |
getInfinispanMarshaller() |
(package private) void |
setCloseListener(RiverCloseListener closeListener) |
void |
setInfinispanMarshaller(StreamingMarshaller infinispanMarshaller) |
private StreamingMarshaller infinispanMarshaller
private RiverCloseListener listener
protected ExtendedRiverUnmarshaller(RiverMarshallerFactory factory, SerializableClassRegistry registry, MarshallingConfiguration cfg)
public StreamingMarshaller getInfinispanMarshaller()
public void setInfinispanMarshaller(StreamingMarshaller infinispanMarshaller)
void setCloseListener(RiverCloseListener closeListener)
public void finish() throws java.io.IOException
java.io.IOException