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

Class SessionHandler

java.lang.Object

com.swiftmq.impl.amqp.amqp.v01_00_00.SessionHandler

All Implemented Interfaces:

AMQPSessionVisitor

public class SessionHandler
extends Object
implements AMQPSessionVisitor

Field Summary

Fields

Modifier and Type	Field	Description
int	msgsReceived
int	msgsSent
int	totalMsgsReceived
int	totalMsgsSent

Constructor Summary

Constructors

Constructor	Description
SessionHandler(SwiftletContext ctx, VersionedConnection versionedConnection, AMQPHandler amqpHandler, BeginFrame beginFrame)

Method Summary

Modifier and Type	Method	Description
void	applyDispositionFrame(DispositionFrame frame)
void	close()
void	collect(long lastCollect)
void	dispatch(POObject po)
int	getChannel()
int	getMsgsReceived()
int	getMsgsSent()
int	getTotalMsgsReceived()
int	getTotalMsgsSent()
TransactionRegistry	getTransactionRegistry()
VersionedConnection	getVersionedConnection()
void	incMsgsReceived(int n)
void	incMsgsSent(int n)
void	sendOutboundDeliveries()
void	setChannel(int channel)
void	settleOutbound(long deliveryId, DeliveryStateIF deliveryState)
void	setUsage(Entity usage)
void	startSession()
void	stopSession()
String	toString()
void	visit(POCloseSession po)
void	visit(POSendBegin po)
void	visit(POSendEnd po)
void	visit(POSendFlow po)
void	visit(POSendMessages po)
void	visit(POSessionCollect po)
void	visit(POSessionFrameReceived po)

Methods inherited from class java.lang.Object

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

Field Details

msgsReceived

public volatile int msgsReceived

msgsSent

public volatile int msgsSent

totalMsgsReceived

public volatile int totalMsgsReceived

totalMsgsSent

public volatile int totalMsgsSent

Constructor Details

SessionHandler

public SessionHandler(SwiftletContext ctx,
 VersionedConnection versionedConnection,
 AMQPHandler amqpHandler,
 BeginFrame beginFrame)

Method Details

getMsgsReceived

public int getMsgsReceived()

getMsgsSent

public int getMsgsSent()

getTotalMsgsReceived

public int getTotalMsgsReceived()

getTotalMsgsSent

public int getTotalMsgsSent()

incMsgsSent

public void incMsgsSent(int n)

incMsgsReceived

public void incMsgsReceived(int n)

setUsage

public void setUsage(Entity usage)

settleOutbound

public void settleOutbound(long deliveryId,
 DeliveryStateIF deliveryState)
                    throws EndWithErrorException

Throws:

EndWithErrorException

applyDispositionFrame

public void applyDispositionFrame(DispositionFrame frame)
                           throws EndWithErrorException

Throws:

EndWithErrorException

sendOutboundDeliveries

public void sendOutboundDeliveries()
                            throws EndWithErrorException

Throws:

EndWithErrorException

getVersionedConnection

public VersionedConnection getVersionedConnection()

getChannel

public int getChannel()

setChannel

public void setChannel(int channel)

getTransactionRegistry

public TransactionRegistry getTransactionRegistry()

startSession

public void startSession()

stopSession

public void stopSession()

dispatch

public void dispatch(POObject po)

collect

public void collect(long lastCollect)

visit

public void visit(POSessionFrameReceived po)

Specified by:

visit in interface AMQPSessionVisitor

visit

public void visit(POSendBegin po)

Specified by:

visit in interface AMQPSessionVisitor

visit

public void visit(POSendMessages po)

Specified by:

visit in interface AMQPSessionVisitor

visit

public void visit(POSendFlow po)

Specified by:

visit in interface AMQPSessionVisitor

visit

public void visit(POSessionCollect po)

Specified by:

visit in interface AMQPSessionVisitor

visit

public void visit(POSendEnd po)

Specified by:

visit in interface AMQPSessionVisitor

visit

public void visit(POCloseSession po)

Specified by:

visit in interface AMQPSessionVisitor

close

public void close()

toString

public String toString()

Overrides:

toString in class Object