com.caucho.amqp.io
Class AmqpConnectionWriter
java.lang.Object
com.caucho.amqp.io.AmqpConnectionWriter
public class AmqpConnectionWriter
- extends java.lang.Object
Amqp server connection
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 |
AmqpConnectionWriter
public AmqpConnectionWriter(WriteStream os)
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