weblogic.jms.common

Class BufferDataOutputStream

java.lang.Object

java.io.OutputStream

weblogic.jms.common.BufferOutputStream

weblogic.jms.common.BufferDataOutputStream

All Implemented Interfaces:

java.io.Closeable, java.io.DataOutput, java.io.Flushable, java.io.ObjectOutput, java.lang.AutoCloseable, JMSOutputStream, Payload, PayloadStream, PayloadText

public final class BufferDataOutputStream
extends BufferOutputStream
implements PayloadStream, PayloadText, java.io.ObjectOutput

BufferDataOutputStream

This class is an "unsychronized byte array data output stream". It combines the functionality of java.io.DataOuputStream and java.io.ByteArrayOutputStream but unlike them does not use synchronized methods.

When the fixedSizeBuf constructor is used, the supplied buffer is never replaced. Writes that would exceed that size throw. Otherwise A modified buffer resizing algorithm is used. Instead of always doubling the internal buffer size if it is too small, doubling occurs only at less than 2MB, for larger size the buffer size increases in fixed increments.

Excluded in public API Reference.

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	buf
private int	count
private byte[]	fixedSizeBuf
private boolean	isBypassOutputStream
private boolean	isJMSMulticastOutputStream
private boolean	isJMSStoreOutputStream
private ObjectIOBypass	objectIOBypass
private static int	VERSION

Constructor Summary

Constructors

Constructor and Description
BufferDataOutputStream(ObjectIOBypass objectIOBypass, byte[] fixedSizeBuf)
BufferDataOutputStream(ObjectIOBypass objectIOBypass, java.io.DataInput in)
BufferDataOutputStream(ObjectIOBypass objectIOBypass, java.io.DataInput in, int count)
BufferDataOutputStream(ObjectIOBypass objectIOBypass, int size)

Method Summary

Modifier and Type	Method and Description
(package private) void	copyBuffer()
PayloadStream	copyPayloadWithoutSharedStream() copy the underlying buffers to a new payload.
PayloadText	copyPayloadWithoutSharedText() copy the underlying buffers to a new payload.
byte[]	getBuffer()
BufferInputStream	getInputStream() get an InputStream for this data
int	getLength()
java.io.ObjectOutput	getObjectOutput()
boolean	isBypassOutputStream()
boolean	isJMSMulticastOutputStream()
boolean	isJMSStoreOutputStream()
PayloadStream	moveToPayload() destructively move the data to a payload.
java.lang.String	readUTF8()
void	reset()
private void	resizeBuf(int oldSize, int minSize) Ensure the internal buffer is large enough.
void	setIsBypassOutputStream()
void	setIsJMSMulticastOutputStream()
void	setIsJMSStoreOutputStream()
int	size()
void	write(byte[] b, int off, int len)
void	write(int b)
void	writeBoolean(boolean data)
void	writeByte(int data)
void	writeBytes(java.lang.String s)
void	writeChar(int data)
void	writeChars(java.lang.String s)
void	writeDouble(double data)
void	writeFloat(float data)
void	writeInt(int data)
void	writeLengthAndData(java.io.DataOutput out) out.writeInt(getLength()) and then write() all data to out.
void	writeLong(long data)
void	writeObject(java.lang.Object o) A special version of writeObject.
void	writeShort(int data)
void	writeTo(java.io.OutputStream out) same as writeLengthAndData without writing the Length
void	writeUTF(java.lang.String str)
static void	writeUTF32(java.io.ObjectOutput out, java.lang.String str)
void	writeUTF32(java.lang.String str)

Methods inherited from class java.io.OutputStream

close, flush, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.ObjectOutput

close, flush, write

Field Detail

buf

private byte[] buf

fixedSizeBuf

private final byte[] fixedSizeBuf

count

private int count

objectIOBypass

private final ObjectIOBypass objectIOBypass

isBypassOutputStream

private boolean isBypassOutputStream

isJMSStoreOutputStream

private boolean isJMSStoreOutputStream

isJMSMulticastOutputStream

private boolean isJMSMulticastOutputStream

VERSION

private static final int VERSION

See Also:

Constant Field Values

Constructor Detail

BufferDataOutputStream

public BufferDataOutputStream(ObjectIOBypass objectIOBypass,
                              int size)

BufferDataOutputStream

public BufferDataOutputStream(ObjectIOBypass objectIOBypass,
                              byte[] fixedSizeBuf)

BufferDataOutputStream

BufferDataOutputStream(ObjectIOBypass objectIOBypass,
                       java.io.DataInput in)
                throws java.io.IOException

Throws:

java.io.IOException

BufferDataOutputStream

BufferDataOutputStream(ObjectIOBypass objectIOBypass,
                       java.io.DataInput in,
                       int count)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

resizeBuf

private void resizeBuf(int oldSize,
                       int minSize)
                throws java.io.IOException

Ensure the internal buffer is large enough. A modified resizing algorithm is used in an attempt to conserve memory.

Throws:

java.io.IOException

See Also:

BufferOutputStream

isJMSStoreOutputStream

public final boolean isJMSStoreOutputStream()

Specified by:

isJMSStoreOutputStream in class BufferOutputStream

isBypassOutputStream

public final boolean isBypassOutputStream()

Specified by:

isBypassOutputStream in interface JMSOutputStream

isJMSMulticastOutputStream

public final boolean isJMSMulticastOutputStream()

Specified by:

isJMSMulticastOutputStream in interface JMSOutputStream

setIsJMSStoreOutputStream

public final void setIsJMSStoreOutputStream()

Specified by:

setIsJMSStoreOutputStream in class BufferOutputStream

setIsBypassOutputStream

public final void setIsBypassOutputStream()

Specified by:

setIsBypassOutputStream in class BufferOutputStream

setIsJMSMulticastOutputStream

public final void setIsJMSMulticastOutputStream()

Specified by:

setIsJMSMulticastOutputStream in class BufferOutputStream

write

public final void write(int b)
                 throws java.io.IOException

Specified by:

write in interface java.io.DataOutput

Specified by:

write in interface java.io.ObjectOutput

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

write

public final void write(byte[] b,
                        int off,
                        int len)
                 throws java.io.IOException

Specified by:

write in interface java.io.DataOutput

Specified by:

write in interface java.io.ObjectOutput

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

writeTo

public final void writeTo(java.io.OutputStream out)
                   throws java.io.IOException

Description copied from interface: Payload

same as writeLengthAndData without writing the Length

Specified by:

writeTo in interface Payload

Throws:

java.io.IOException

reset

public final void reset()

Specified by:

reset in class BufferOutputStream

getBuffer

public final byte[] getBuffer()

getObjectOutput

public final java.io.ObjectOutput getObjectOutput()

Specified by:

getObjectOutput in class BufferOutputStream

copyBuffer

final void copyBuffer()
               throws JMSException

Specified by:

copyBuffer in class BufferOutputStream

Throws:

JMSException

size

public final int size()

Specified by:

size in class BufferOutputStream

writeObject

public final void writeObject(java.lang.Object o)
                       throws java.io.IOException

A special version of writeObject. It only works with classes that are entered in "ObjectIOBypass".

Specified by:

writeObject in interface java.io.ObjectOutput

Throws:

java.io.IOException

See Also:

weblogic.jms.store.ObjectIOBypass

writeBoolean

public final void writeBoolean(boolean data)
                        throws java.io.IOException

Specified by:

writeBoolean in interface java.io.DataOutput

Throws:

java.io.IOException

writeByte

public final void writeByte(int data)
                     throws java.io.IOException

Specified by:

writeByte in interface java.io.DataOutput

Throws:

java.io.IOException

writeShort

public final void writeShort(int data)
                      throws java.io.IOException

Specified by:

writeShort in interface java.io.DataOutput

Throws:

java.io.IOException

writeChar

public final void writeChar(int data)
                     throws java.io.IOException

Specified by:

writeChar in interface java.io.DataOutput

Throws:

java.io.IOException

writeInt

public final void writeInt(int data)
                    throws java.io.IOException

Specified by:

writeInt in interface java.io.DataOutput

Throws:

java.io.IOException

writeLong

public final void writeLong(long data)
                     throws java.io.IOException

Specified by:

writeLong in interface java.io.DataOutput

Throws:

java.io.IOException

writeFloat

public final void writeFloat(float data)
                      throws java.io.IOException

Specified by:

writeFloat in interface java.io.DataOutput

Throws:

java.io.IOException

writeDouble

public final void writeDouble(double data)
                       throws java.io.IOException

Specified by:

writeDouble in interface java.io.DataOutput

Throws:

java.io.IOException

writeBytes

public final void writeBytes(java.lang.String s)
                      throws java.io.IOException

Specified by:

writeBytes in interface java.io.DataOutput

Throws:

java.io.IOException

writeChars

public final void writeChars(java.lang.String s)
                      throws java.io.IOException

Specified by:

writeChars in interface java.io.DataOutput

Throws:

java.io.IOException

writeUTF32

public final void writeUTF32(java.lang.String str)
                      throws java.io.IOException

Specified by:

writeUTF32 in class BufferOutputStream

Throws:

java.io.IOException

writeUTF32

public static void writeUTF32(java.io.ObjectOutput out,
                              java.lang.String str)
                       throws java.io.IOException

Throws:

java.io.IOException

writeUTF

public final void writeUTF(java.lang.String str)
                    throws java.io.IOException

Specified by:

writeUTF in interface java.io.DataOutput

Throws:

java.io.IOException

writeLengthAndData

public void writeLengthAndData(java.io.DataOutput out)
                        throws java.io.IOException

Description copied from interface: Payload

out.writeInt(getLength()) and then write() all data to out. if the underlying PayloadImpl has a faster way to transfer the data use it.

Specified by:

writeLengthAndData in interface Payload

Throws:

java.io.IOException

copyPayloadWithoutSharedText

public PayloadText copyPayloadWithoutSharedText()
                                         throws JMSException

Description copied from interface: PayloadText

copy the underlying buffers to a new payload. No shared data

Specified by:

copyPayloadWithoutSharedText in interface PayloadText

Throws:

JMSException

copyPayloadWithoutSharedStream

public PayloadStream copyPayloadWithoutSharedStream()
                                             throws JMSException

Description copied from class: BufferOutputStream

copy the underlying buffers to a new payload. No shared data

Specified by:

copyPayloadWithoutSharedStream in interface PayloadStream

Specified by:

copyPayloadWithoutSharedStream in class BufferOutputStream

Throws:

JMSException

moveToPayload

public PayloadStream moveToPayload()

Description copied from class: BufferOutputStream

destructively move the data to a payload. this.BufferOutputStream.internal will NPE

Specified by:

moveToPayload in class BufferOutputStream

getInputStream

public BufferInputStream getInputStream()
                                 throws java.io.IOException

Description copied from interface: Payload

get an InputStream for this data

Specified by:

getInputStream in interface Payload

Throws:

java.io.IOException

getLength

public int getLength()

Specified by:

getLength in interface Payload

readUTF8

public java.lang.String readUTF8()
                          throws java.io.IOException

Specified by:

readUTF8 in interface PayloadText

Throws:

java.io.IOException