Package com.swiftmq.impl.jms.standard.v400

Class InboundReader

java.lang.Object

com.swiftmq.tools.requestreply.RequestServiceRegistry

com.swiftmq.impl.jms.standard.v400.InboundReader

All Implemented Interfaces:

InboundHandler

public class InboundReader
extends RequestServiceRegistry
implements InboundHandler

Method Summary

Modifier and Type	Method	Description
void	dataAvailable(Connection connection, java.io.InputStream inputStream)	Will be called if data is available on the connection's input stream.

Methods inherited from class com.swiftmq.tools.requestreply.RequestServiceRegistry

addRequestService, dispatch, getNextFreeDispatchId, getNumberServices, getRequestService, isSendExceptionEnabled, removeRequestService, setReplyHandler

Methods inherited from class java.lang.Object

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

Method Detail

dataAvailable

public void dataAvailable(Connection connection,
                          java.io.InputStream inputStream)
                   throws java.io.IOException

Description copied from interface: InboundHandler

Will be called if data is available on the connection's input stream. The inbound handler must read this data out of the stream and should forward it to further processing to some async running task to return immediately. If this method throws an IOException, the connection will be closed.

Specified by:

dataAvailable in interface InboundHandler

Parameters:

connection - connection.

inputStream - the connections's input stream.

Throws:

java.io.IOException - on error to close the connection.