Package com.webmethods.jms.impl

Class WmJMSInputStream

java.lang.Object

java.io.InputStream

com.webmethods.jms.impl.WmJMSInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, javax.jms.ExceptionListener, javax.jms.MessageListener

public class WmJMSInputStream
extends java.io.InputStream
implements javax.jms.MessageListener, javax.jms.ExceptionListener

Constructor Summary

Constructors

Constructor	Description
WmJMSInputStream(WmMessageConsumerImpl consumer)

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
int	currentReadBytePosition()	Get the current byte position which has been read by the client
long	getReadTimeout()
java.lang.String	getStreamId()
void	markStreamBytePosition(int position)	Set the stream byte position for recovery
void	onException(javax.jms.JMSException ex)
void	onMessage(javax.jms.Message msg)
int	read()
void	setReadTimeout(long timeout)
void	setStreamId(java.lang.String streamId)

Methods inherited from class java.io.InputStream

mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo

Methods inherited from class java.lang.Object

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

Constructor Detail

WmJMSInputStream

public WmJMSInputStream(WmMessageConsumerImpl consumer)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

available

public int available()
              throws java.io.IOException

Overrides:

available in class java.io.InputStream

Throws:

java.io.IOException

setStreamId

public void setStreamId(java.lang.String streamId)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getStreamId

public java.lang.String getStreamId()

markStreamBytePosition

public void markStreamBytePosition(int position)

Set the stream byte position for recovery

Parameters:

position -

currentReadBytePosition

public int currentReadBytePosition()

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

setReadTimeout

public void setReadTimeout(long timeout)

getReadTimeout

public long getReadTimeout()

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.InputStream

Throws:

java.io.IOException

onException

public void onException(javax.jms.JMSException ex)

Specified by:

onException in interface javax.jms.ExceptionListener

onMessage

public void onMessage(javax.jms.Message msg)

Specified by:

onMessage in interface javax.jms.MessageListener