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

Constructor Summary

Constructors

Constructor and Description
AmqpConnectionHandler(AmqpLinkFactory linkFactory, ReadStream is, WriteStream os)

Method Summary

Modifier and Type	Method and Description
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()