org.apache.activemq
Class ActiveMQInputStream

java.lang.Object
  extended by java.io.InputStream
      extended by 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 javax.jms.JMSException
Throws:
javax.jms.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 javax.jms.JMSException
Throws:
javax.jms.JMSException

checkClosed

protected void checkClosed()
                    throws javax.jms.IllegalStateException
Throws:
javax.jms.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


Copyright © 2011 Apache Software Foundation. All Rights Reserved.