com.caucho.amqp.common
Class AmqpConnectionHandler

java.lang.Object
  extended by com.caucho.amqp.common.AmqpConnectionHandler
All Implemented Interfaces:
AmqpFrameHandler

public class AmqpConnectionHandler
extends java.lang.Object
implements AmqpFrameHandler

Amqp server connection


Constructor Summary
AmqpConnectionHandler(AmqpLinkFactory linkFactory, ReadStream is, WriteStream os)
           
 
Method Summary
 AmqpSession beginSession()
           
 void closeConnection()
           
 void closeSender(AmqpLink link)
           
 void closeSessions()
           
 void flow(AmqpLink link, long deliveryCount, int credit)
           
 AmqpConnectionReader getReader()
           
 AmqpConnectionWriter getWriter()
           
 void onAttach(FrameAttach attach)
           
 void onBegin(FrameBegin beginRequest)
          Receives a session-begin frame.
 void onClose(FrameClose clientClose)
           
 void onDetach(FrameDetach clientDetach)
           
 void onDisposition(FrameDisposition disposition)
           
 void onEnd(FrameEnd clientEnd)
           
 void onFlow(FrameFlow flow)
           
 void onTransfer(AmqpReader ain, FrameTransfer transfer)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AmqpConnectionHandler

public AmqpConnectionHandler(AmqpLinkFactory linkFactory,
                             ReadStream is,
                             WriteStream os)
Method Detail

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()