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

Class ChannelHandler

java.lang.Object

com.swiftmq.impl.amqp.amqp.v00_09_01.ChannelHandler

All Implemented Interfaces:

AMQPChannelVisitor, DestinationFactory

public class ChannelHandler
extends Object
implements AMQPChannelVisitor, DestinationFactory

Constructor Summary

Constructors

Constructor	Description
ChannelHandler(SwiftletContext ctx, AMQPHandler amqpHandler, int channelNo)

Method Summary

Modifier and Type	Method	Description
void	addUnacked(long deliveryTag, Consumer consumer, MessageIndex messageIndex, int size)
void	close()
Destination	create(String name)
void	dispatch(POObject po)
int	getChannelNo()
long	getNextDeliveryTag()
VersionedConnection	getVersionedConnection()
String	toString()
void	visit(POActivateFlow po)
void	visit(POChannelFrameReceived po)
void	visit(POCloseChannel po)
void	visit(POSendMessages po)

Methods inherited from class java.lang.Object

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

Constructor Details

ChannelHandler

public ChannelHandler(SwiftletContext ctx,
 AMQPHandler amqpHandler,
 int channelNo)

Method Details

getChannelNo

public int getChannelNo()

getVersionedConnection

public VersionedConnection getVersionedConnection()

dispatch

public void dispatch(POObject po)

create

public Destination create(String name)

Specified by:

create in interface DestinationFactory

getNextDeliveryTag

public long getNextDeliveryTag()

addUnacked

public void addUnacked(long deliveryTag,
 Consumer consumer,
 MessageIndex messageIndex,
 int size)

visit

public void visit(POChannelFrameReceived po)

Specified by:

visit in interface AMQPChannelVisitor

visit

public void visit(POSendMessages po)

Specified by:

visit in interface AMQPChannelVisitor

visit

public void visit(POActivateFlow po)

Specified by:

visit in interface AMQPChannelVisitor

visit

public void visit(POCloseChannel po)

Specified by:

visit in interface AMQPChannelVisitor

close

public void close()

toString

public String toString()

Overrides:

toString in class Object