Package com.swiftmq.impl.amqp.amqp.v00_09_01

Class AMQPHandler

java.lang.Object

com.swiftmq.impl.amqp.amqp.v00_09_01.AMQPHandler

All Implemented Interfaces:

AMQPConnectionVisitor, Handler, InboundHandler, POVisitor

public class AMQPHandler
extends java.lang.Object
implements Handler, AMQPConnectionVisitor

Constructor Summary

Constructors

Constructor	Description
AMQPHandler(SwiftletContext ctx, VersionedConnection versionedConnection)

Method Summary

Modifier and Type	Method	Description
void	addTempQueue(java.lang.String name)
void	close()
void	collect(long lastCollect)
void	dataAvailable(LengthCaptureDataInput lengthCaptureDataInput)
void	dispatch(POObject po)
ActiveLogin	getActiveLogin()
int	getMaxFrameSize()
java.lang.String	getVersion()
VersionedConnection	getVersionedConnection()
void	removeTempQueue(java.lang.String name)
void	toPayload(Frame frame, ContentHeaderProperties contentHeaderProperties)
void	toPayload(Frame frame, Method method)
java.lang.String	toString()
void	visit(POCheckIdleTimeout po)
void	visit(POClose po)
void	visit(POSendChannelClose po)
void	visit(POSendClose po)
void	visit(POSendHeartBeat po)
void	visit(POSendStart po)
void	visit(POSendTune po)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPHandler

public AMQPHandler(SwiftletContext ctx,
                   VersionedConnection versionedConnection)

Method Detail

toPayload

public void toPayload(Frame frame,
                      Method method)

toPayload

public void toPayload(Frame frame,
                      ContentHeaderProperties contentHeaderProperties)

getMaxFrameSize

public int getMaxFrameSize()

addTempQueue

public void addTempQueue(java.lang.String name)

removeTempQueue

public void removeTempQueue(java.lang.String name)

getVersionedConnection

public VersionedConnection getVersionedConnection()

getActiveLogin

public ActiveLogin getActiveLogin()

getVersion

public java.lang.String getVersion()

Specified by:

getVersion in interface Handler

collect

public void collect(long lastCollect)

Specified by:

collect in interface Handler

dispatch

public void dispatch(POObject po)

visit

public void visit(POSendStart po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POSendTune po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POSendHeartBeat po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POCheckIdleTimeout po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POSendChannelClose po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POSendClose po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POClose po)

Specified by:

visit in interface AMQPConnectionVisitor

close

public void close()

Specified by:

close in interface Handler

dataAvailable

public void dataAvailable(LengthCaptureDataInput lengthCaptureDataInput)

Specified by:

dataAvailable in interface InboundHandler

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object