com.caucho.amqp.common
Class AmqpConnectionHandler
java.lang.Object
com.caucho.amqp.common.AmqpConnectionHandler
- All Implemented Interfaces:
- AmqpFrameHandler
public class AmqpConnectionHandler
- extends java.lang.Object
- implements AmqpFrameHandler
Amqp server connection
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AmqpConnectionHandler
public AmqpConnectionHandler(AmqpLinkFactory linkFactory,
ReadStream is,
WriteStream os)
getReader
public AmqpConnectionReader getReader()
getWriter
public AmqpConnectionWriter getWriter()
beginSession
public AmqpSession beginSession()
onBegin
public void onBegin(FrameBegin beginRequest)
throws java.io.IOException
- Description copied from interface:
AmqpFrameHandler
- Receives a session-begin frame.
- Specified by:
onBegin
in interface AmqpFrameHandler
- Throws:
java.io.IOException
onEnd
public void onEnd(FrameEnd clientEnd)
throws java.io.IOException
- Specified by:
onEnd
in interface AmqpFrameHandler
- Throws:
java.io.IOException
onAttach
public void onAttach(FrameAttach attach)
- Specified by:
onAttach
in interface AmqpFrameHandler
closeSender
public void closeSender(AmqpLink link)
onDetach
public void onDetach(FrameDetach clientDetach)
throws java.io.IOException
- Specified by:
onDetach
in interface AmqpFrameHandler
- Throws:
java.io.IOException
onTransfer
public void onTransfer(AmqpReader ain,
FrameTransfer transfer)
throws java.io.IOException
- Specified by:
onTransfer
in interface AmqpFrameHandler
- Throws:
java.io.IOException
onDisposition
public void onDisposition(FrameDisposition disposition)
throws java.io.IOException
- Specified by:
onDisposition
in interface AmqpFrameHandler
- Throws:
java.io.IOException
flow
public void flow(AmqpLink link,
long deliveryCount,
int credit)
- Parameters:
handle
-
onFlow
public void onFlow(FrameFlow flow)
throws java.io.IOException
- Specified by:
onFlow
in interface AmqpFrameHandler
- Throws:
java.io.IOException
onClose
public void onClose(FrameClose clientClose)
throws java.io.IOException
- Specified by:
onClose
in interface AmqpFrameHandler
- Throws:
java.io.IOException
closeSessions
public void closeSessions()
closeConnection
public void closeConnection()