public interface ServerChannelMethodProcessor extends ChannelMethodProcessor
Modifier and Type | Method and Description |
---|---|
void |
receiveAccessRequest(AMQShortString realm,
boolean exclusive,
boolean passive,
boolean active,
boolean write,
boolean read) |
void |
receiveBasicAck(long deliveryTag,
boolean multiple) |
void |
receiveBasicCancel(AMQShortString consumerTag,
boolean noWait) |
void |
receiveBasicConsume(AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments) |
void |
receiveBasicGet(AMQShortString queue,
boolean noAck) |
void |
receiveBasicPublish(AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate) |
void |
receiveBasicQos(long prefetchSize,
int prefetchCount,
boolean global) |
void |
receiveBasicRecover(boolean requeue,
boolean sync) |
void |
receiveBasicReject(long deliveryTag,
boolean requeue) |
void |
receiveConfirmSelect(boolean nowait) |
void |
receiveExchangeBound(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue) |
void |
receiveExchangeDeclare(AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments) |
void |
receiveExchangeDelete(AMQShortString exchange,
boolean ifUnused,
boolean nowait) |
void |
receiveQueueBind(AMQShortString queue,
AMQShortString exchange,
AMQShortString bindingKey,
boolean nowait,
FieldTable arguments) |
void |
receiveQueueDeclare(AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments) |
void |
receiveQueueDelete(AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait) |
void |
receiveQueuePurge(AMQShortString queue,
boolean nowait) |
void |
receiveQueueUnbind(AMQShortString queue,
AMQShortString exchange,
AMQShortString bindingKey,
FieldTable arguments) |
void |
receiveTxCommit() |
void |
receiveTxRollback() |
void |
receiveTxSelect() |
ignoreAllButCloseOk, receiveBasicNack, receiveChannelClose, receiveChannelCloseOk, receiveChannelFlow, receiveChannelFlowOk, receiveMessageContent, receiveMessageHeader
void receiveAccessRequest(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
void receiveExchangeDeclare(AMQShortString exchange, AMQShortString type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
void receiveExchangeDelete(AMQShortString exchange, boolean ifUnused, boolean nowait)
void receiveExchangeBound(AMQShortString exchange, AMQShortString routingKey, AMQShortString queue)
void receiveQueueDeclare(AMQShortString queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
void receiveQueueBind(AMQShortString queue, AMQShortString exchange, AMQShortString bindingKey, boolean nowait, FieldTable arguments)
void receiveQueuePurge(AMQShortString queue, boolean nowait)
void receiveQueueDelete(AMQShortString queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
void receiveQueueUnbind(AMQShortString queue, AMQShortString exchange, AMQShortString bindingKey, FieldTable arguments)
void receiveBasicRecover(boolean requeue, boolean sync)
void receiveBasicQos(long prefetchSize, int prefetchCount, boolean global)
void receiveBasicConsume(AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable arguments)
void receiveBasicCancel(AMQShortString consumerTag, boolean noWait)
void receiveBasicPublish(AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
void receiveBasicGet(AMQShortString queue, boolean noAck)
void receiveBasicAck(long deliveryTag, boolean multiple)
receiveBasicAck
in interface ChannelMethodProcessor
void receiveBasicReject(long deliveryTag, boolean requeue)
void receiveTxSelect()
void receiveTxCommit()
void receiveTxRollback()
void receiveConfirmSelect(boolean nowait)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.