com.caucho.amqp.io

Class AmqpConnectionWriter

java.lang.Object

com.caucho.amqp.io.AmqpConnectionWriter

public class AmqpConnectionWriter
extends java.lang.Object

Amqp server connection

Constructor Summary

Constructors

Constructor and Description
AmqpConnectionWriter(WriteStream os)

Method Summary

Modifier and Type	Method and Description
void	attachReceiver(AmqpSession session, AmqpLink link, DistributionMode distMode, SettleMode settleMode)
void	attachReply(AmqpSession session, AmqpLink link)
void	attachSender(AmqpSession session, AmqpLink link, SettleMode settleMode)
void	disconnect()
void	flush()
void	sendDisposition(AmqpSession session, long deliveryId, DeliveryState state, boolean isSettled)
void	sendFlow(AmqpSession session, AmqpLink link, long deliveryCount, int credit)
void	sendFrame(AmqpAbstractFrame frame)
void	sendFrame(int channel, AmqpAbstractFrame frame)
void	sendSaslChallenge()
void	transfer(AmqpSession session, AmqpSenderLink link, long deliveryId, SettleMode settleMode, java.io.InputStream is) Transfers a message.
void	writeBegin()
void	writeOpen()
void	writeVersion(int code)

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpConnectionWriter

public AmqpConnectionWriter(WriteStream os)

Method Detail

writeVersion

public void writeVersion(int code)
                  throws java.io.IOException

Throws:

java.io.IOException

writeOpen

public void writeOpen()

writeBegin

public void writeBegin()

attachSender

public void attachSender(AmqpSession session,
                         AmqpLink link,
                         SettleMode settleMode)

attachReceiver

public void attachReceiver(AmqpSession session,
                           AmqpLink link,
                           DistributionMode distMode,
                           SettleMode settleMode)

attachReply

public void attachReply(AmqpSession session,
                        AmqpLink link)

transfer

public void transfer(AmqpSession session,
                     AmqpSenderLink link,
                     long deliveryId,
                     SettleMode settleMode,
                     java.io.InputStream is)

Transfers a message.

sendDisposition

public void sendDisposition(AmqpSession session,
                            long deliveryId,
                            DeliveryState state,
                            boolean isSettled)

sendFlow

public void sendFlow(AmqpSession session,
                     AmqpLink link,
                     long deliveryCount,
                     int credit)

Parameters:

handle -

disconnect

public void disconnect()

sendFrame

public void sendFrame(AmqpAbstractFrame frame)

sendFrame

public void sendFrame(int channel,
                      AmqpAbstractFrame frame)

flush

public void flush()

sendSaslChallenge

public void sendSaslChallenge()
                       throws java.io.IOException

Throws:

java.io.IOException