AMQP 0.9.1 Quick Reference, quickref
| 命令 | Java API (Channel接口) | 功能描述 |
|---|---|---|
| basic | ||
| basic.ack | basicAck | Acknowledge one or more messages |
| basic.cancel | basicCancel | End a queue consumer |
| basic.consume | basicConsume | Start a queue consumer |
| basic.deliver | - | Notify the client of a consumer message |
| basic.get | basicGet | Direct access to a queue |
| basic.nack | basicNack | Reject one or more incoming messages |
| basic.publish | basicPublish | Publish a message |
| basic.qos | basicQos | Specify quality of service |
| basic.recover | basicRecover | Redeliver unacknowledged messages |
| basic.recover-async | - | Redeliver unacknowledged messages |
| basic.reject | basicReject | Reject an incoming message |
| basic.return | - | Return a failed message |
| channel | ||
| channel.close | close | Request a channel close |
| channel.flow | - | Enable/disable flow from peer |
| channel.open | - | Open a channel for use |
| confirm | ||
| confirm.select | confirmSelect | Enables publisher acknowledgements on this channel |
| exchange | ||
| exchange.bind | exchangeBind | Bind exchange to an exchange |
| exchange.declare | exchangeDeclare | Verify exchange exists, create if needed |
| exchange.delete | exchangeDelete | Delete an exchange |
| exchange.unbind | exchangeUnbind | Unbind an exchange from an exchange |
| queue | ||
| queue.bind | queueBind | Bind queue to an exchange |
| queue.declare | queueDeclare | Declare queue, create if needed |
| queue.delete | queueDelete | Delete a queue |
| queue.purge | queuePurge | Purge a queue |
| queue.unbind | queueUnbind | Unbind a queue from an exchange |
| tx | ||
| tx.commit | txCommit | Commit the current transaction |
| tx.rollback | txRollback | Abandon the current transaction |
| tx.select | txSelect | Select standard transaction mode |