Package com.webmethods.jms.impl

Class WmJMSOutputStream

java.lang.Object

java.io.OutputStream

com.webmethods.jms.impl.WmJMSOutputStream

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

public class WmJMSOutputStream
extends java.io.OutputStream

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_PACKET_SIZE

Constructor Summary

Constructors

Constructor	Description
WmJMSOutputStream(WmMessageProducerImpl producer)
WmJMSOutputStream(WmMessageProducerImpl producer, int packetSize)

Method Summary

Modifier and Type	Method	Description
void	close()
int	currentWrittenBytePosition()	Get the current byte position which has been written by the client
void	flush()
java.lang.String	getStreamId()
void	markStreamBytePosition(int position)	Set the stream byte position for recovery
void	setStreamId(java.lang.String streamId)
void	write(int b)

Methods inherited from class java.io.OutputStream

nullOutputStream, write, write

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PACKET_SIZE

public static final int DEFAULT_PACKET_SIZE

See Also:

Constant Field Values

Constructor Detail

WmJMSOutputStream

public WmJMSOutputStream(WmMessageProducerImpl producer,
                         int packetSize)

WmJMSOutputStream

public WmJMSOutputStream(WmMessageProducerImpl producer)

Method Detail

write

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

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

setStreamId

public void setStreamId(java.lang.String streamId)

getStreamId

public java.lang.String getStreamId()

markStreamBytePosition

public void markStreamBytePosition(int position)

Set the stream byte position for recovery

Parameters:

position -

currentWrittenBytePosition

public int currentWrittenBytePosition()

Get the current byte position which has been written by the client

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Overrides:

flush in class java.io.OutputStream

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class java.io.OutputStream

Throws:

java.io.IOException