Package org.jboss.marshalling.river
Class BlockMarshaller
java.lang.Object
org.jboss.marshalling.river.BlockMarshaller
- All Implemented Interfaces:
Closeable
,DataOutput
,Flushable
,ObjectOutput
,AutoCloseable
,ByteOutput
,Marshaller
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Discard the class cache.void
Discard the instance cache.void
close()
private void
doWriteObject
(Object obj, boolean unshared) void
finish()
Finish marshalling to a stream.void
flush()
void
start
(ByteOutput newOutput) Begin marshalling to a stream.void
write
(byte[] b) Write all the bytes from the given array to the stream.void
write
(byte[] bytes, int off, int len) Write some of the bytes from the given array to the stream.void
write
(int v) Writes to the output stream the eight low-order bits of the argumentb
.void
writeBoolean
(boolean v) void
writeByte
(int v) void
writeBytes
(String s) void
writeChar
(int v) void
writeChars
(String s) void
writeDouble
(double v) void
writeFloat
(float v) void
writeInt
(int v) void
writeLong
(long v) void
writeObject
(Object obj) void
Write an object to the underlying storage or stream as a new instance.void
writeShort
(int v) void
-
Field Details
-
riverMarshaller
-
buffer
private final byte[] buffer -
position
private int position
-
-
Constructor Details
-
BlockMarshaller
BlockMarshaller(RiverMarshaller riverMarshaller, int blockSize)
-
-
Method Details
-
start
Description copied from interface:Marshaller
Begin marshalling to a stream.- Specified by:
start
in interfaceMarshaller
- Parameters:
newOutput
- the new stream- Throws:
IOException
- if an error occurs during setup, such as an error writing the header
-
clearInstanceCache
Description copied from interface:Marshaller
Discard the instance cache. May also discard the class cache in implementations that do not support separated class and instance caches.- Specified by:
clearInstanceCache
in interfaceMarshaller
- Throws:
IOException
- if an error occurs
-
clearClassCache
Description copied from interface:Marshaller
Discard the class cache. Implicitly also discards the instance cache.- Specified by:
clearClassCache
in interfaceMarshaller
- Throws:
IOException
- if an error occurs
-
finish
Description copied from interface:Marshaller
Finish marshalling to a stream. Any transient class or instance cache is discarded. The stream is released. No further marshalling may be done until theMarshaller.start(ByteOutput)
method is again invoked.- Specified by:
finish
in interfaceMarshaller
- Throws:
IOException
- if an error occurs
-
writeObject
- Specified by:
writeObject
in interfaceObjectOutput
- Throws:
IOException
-
doWriteObject
- Throws:
IOException
-
write
Description copied from interface:ByteOutput
Writes to the output stream the eight low-order bits of the argumentb
. The 24 high-order bits ofb
are ignored.- Specified by:
write
in interfaceByteOutput
- Specified by:
write
in interfaceDataOutput
- Specified by:
write
in interfaceObjectOutput
- Parameters:
v
- the byte to write- Throws:
IOException
- if an error occurs
-
write
Description copied from interface:ByteOutput
Write all the bytes from the given array to the stream.- Specified by:
write
in interfaceByteOutput
- Specified by:
write
in interfaceDataOutput
- Specified by:
write
in interfaceObjectOutput
- Parameters:
b
- the byte array- Throws:
IOException
- if an error occurs
-
write
Description copied from interface:ByteOutput
Write some of the bytes from the given array to the stream.- Specified by:
write
in interfaceByteOutput
- Specified by:
write
in interfaceDataOutput
- Specified by:
write
in interfaceObjectOutput
- Parameters:
bytes
- the byte arrayoff
- the index to start writing fromlen
- the number of bytes to write- Throws:
IOException
- if an error occurs
-
writeBoolean
- Specified by:
writeBoolean
in interfaceDataOutput
- Throws:
IOException
-
writeByte
- Specified by:
writeByte
in interfaceDataOutput
- Throws:
IOException
-
writeShort
- Specified by:
writeShort
in interfaceDataOutput
- Throws:
IOException
-
writeChar
- Specified by:
writeChar
in interfaceDataOutput
- Throws:
IOException
-
writeInt
- Specified by:
writeInt
in interfaceDataOutput
- Throws:
IOException
-
writeLong
- Specified by:
writeLong
in interfaceDataOutput
- Throws:
IOException
-
writeFloat
- Specified by:
writeFloat
in interfaceDataOutput
- Throws:
IOException
-
writeDouble
- Specified by:
writeDouble
in interfaceDataOutput
- Throws:
IOException
-
writeBytes
- Specified by:
writeBytes
in interfaceDataOutput
- Throws:
IOException
-
writeChars
- Specified by:
writeChars
in interfaceDataOutput
- Throws:
IOException
-
writeUTF
- Specified by:
writeUTF
in interfaceDataOutput
- Throws:
IOException
-
flush
- Specified by:
flush
in interfaceFlushable
- Specified by:
flush
in interfaceObjectOutput
- Throws:
IOException
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceObjectOutput
- Throws:
IOException
-