com.caucho.amqp.io
Class AmqpConnectionWriter

java.lang.Object
  extended by com.caucho.amqp.io.AmqpConnectionWriter

public class AmqpConnectionWriter
extends java.lang.Object

Amqp server connection


Constructor Summary
AmqpConnectionWriter(WriteStream os)
           
 
Method Summary
 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