Class InboundReader

java.lang.Object
com.swiftmq.tools.requestreply.RequestServiceRegistry
com.swiftmq.impl.jms.standard.v630.InboundReader
All Implemented Interfaces:
com.swiftmq.swiftlet.net.InboundHandler, com.swiftmq.swiftlet.timer.event.TimerListener, EventListener

public class InboundReader extends com.swiftmq.tools.requestreply.RequestServiceRegistry implements com.swiftmq.swiftlet.net.InboundHandler, com.swiftmq.swiftlet.timer.event.TimerListener
  • Method Details

    • performTimeAction

      public void performTimeAction()
      Specified by:
      performTimeAction in interface com.swiftmq.swiftlet.timer.event.TimerListener
    • setClosed

      public void setClosed(boolean closed)
    • isSendExceptionEnabled

      protected boolean isSendExceptionEnabled()
      Overrides:
      isSendExceptionEnabled in class com.swiftmq.tools.requestreply.RequestServiceRegistry
    • dataAvailable

      public void dataAvailable(com.swiftmq.swiftlet.net.Connection connection, InputStream inputStream) throws IOException
      Specified by:
      dataAvailable in interface com.swiftmq.swiftlet.net.InboundHandler
      Throws:
      IOException