Package com.swiftmq.impl.amqp.amqp.v01_00_00

Class AMQPHandler

FrameVisitorAdapter

com.swiftmq.impl.amqp.amqp.v01_00_00.AMQPHandler

All Implemented Interfaces:

AMQPConnectionVisitor, Handler

public class AMQPHandler
extends FrameVisitorAdapter
implements Handler, AMQPConnectionVisitor

Constructor Summary

Constructors

Constructor	Description
AMQPHandler(SwiftletContext ctx, VersionedConnection versionedConnection)

Method Summary

Modifier and Type	Method	Description
void	close()
void	collect(long lastCollect)
void	dataAvailable(LengthCaptureDataInput in)
void	dispatch(POObject po)
int	getMaxFrameSize()
protected SessionHandler	getSessionHandlerForRemoteChannel(int remoteChannel)
String	getVersion()
boolean	isApacheSelectors()
protected void	mapSessionHandlerToRemoteChannel(SessionHandler sessionHandler, int remoteChannel)
String	toString()
protected void	unmapSessionHandlerFromRemoteChannel(int remoteChannel)
void	visit(POCheckIdleTimeout po)
void	visit(POClose po)
void	visit(POConnectionCollect po)
void	visit(POConnectionFrameReceived po)
void	visit(POSendClose po)
void	visit(POSendHeartBeat po)
void	visit(POSendOpen po)

Constructor Details

AMQPHandler

public AMQPHandler(SwiftletContext ctx,
 VersionedConnection versionedConnection)

Method Details

mapSessionHandlerToRemoteChannel

protected void mapSessionHandlerToRemoteChannel(SessionHandler sessionHandler,
 int remoteChannel)

unmapSessionHandlerFromRemoteChannel

protected void unmapSessionHandlerFromRemoteChannel(int remoteChannel)

getSessionHandlerForRemoteChannel

protected SessionHandler getSessionHandlerForRemoteChannel(int remoteChannel)

getMaxFrameSize

public int getMaxFrameSize()

isApacheSelectors

public boolean isApacheSelectors()

dispatch

public void dispatch(POObject po)

dataAvailable

public void dataAvailable(LengthCaptureDataInput in)

collect

public void collect(long lastCollect)

Specified by:

collect in interface Handler

getVersion

public String getVersion()

Specified by:

getVersion in interface Handler

visit

public void visit(POSendOpen po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POConnectionFrameReceived 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(POSendClose po)

Specified by:

visit in interface AMQPConnectionVisitor

visit

public void visit(POConnectionCollect 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

toString

public String toString()