org.apache.activemq
Class ActiveMQInputStream

java.lang.Object
  java.io.InputStream
      org.apache.activemq.ActiveMQInputStream

All Implemented Interfaces:

Closeable, ActiveMQDispatcher

public class ActiveMQInputStream
extends InputStream
implements ActiveMQDispatcher

Version:

$Revision$

Constructor Summary

ActiveMQInputStream(ActiveMQConnection connection, ConsumerId consumerId, ActiveMQDestination dest, String selector, boolean noLocal, String name, int prefetch)

Method Summary

protected void	checkClosed()
void	close()
void	dispatch(MessageDispatch md)
void	dispose()
int	read()
int	read(byte[] b, int off, int len)
ActiveMQMessage	receive()
String	toString()

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveMQInputStream

public ActiveMQInputStream(ActiveMQConnection connection,
                           ConsumerId consumerId,
                           ActiveMQDestination dest,
                           String selector,
                           boolean noLocal,
                           String name,
                           int prefetch)
                    throws JMSException

Throws:

JMSException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException

dispose

public void dispose()

receive

public ActiveMQMessage receive()
                        throws JMSException

Throws:

JMSException

checkClosed

protected void checkClosed()
                    throws IllegalStateException

Throws:

IllegalStateException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

dispatch

public void dispatch(MessageDispatch md)

Specified by:

dispatch in interface ActiveMQDispatcher

toString

public String toString()

Overrides:

toString in class Object