Documentation ¶
Index ¶
- type Channel
- func (this *Channel) AcknowledgeMultipleMessages(deliveryTag uint64) error
- func (this *Channel) AcknowledgeSingleMessage(deliveryTag uint64) error
- func (this *Channel) BindExchangeToQueue(queue, exchange string) error
- func (this *Channel) CancelConsumer(consumerName string) error
- func (this *Channel) Close() error
- func (this *Channel) CommitTransaction() error
- func (this *Channel) ConfigureChannelAsTransactional() error
- func (this *Channel) ConfigureChannelBuffer(messageCount int) error
- func (this *Channel) Consume(queueName, consumerName string) (<-chan amqp.Delivery, error)
- func (this *Channel) ConsumeWithoutAcknowledgement(queueName, consumerName string) (<-chan amqp.Delivery, error)
- func (this *Channel) DeclareExchange(name, kind string) error
- func (this *Channel) DeclareQueue(name string) error
- func (this *Channel) DeclareTransientQueue() (string, error)
- func (this *Channel) ExclusiveConsume(queueName, consumerName string) (<-chan amqp.Delivery, error)
- func (this *Channel) ExclusiveConsumeWithoutAcknowledgement(queueName, consumerName string) (<-chan amqp.Delivery, error)
- func (this *Channel) PublishMessage(destination, partition string, message amqp.Publishing) error
- func (this *Channel) RollbackTransaction() error
- type Connection
- type Connector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
func (*Channel) AcknowledgeMultipleMessages ¶
func (*Channel) AcknowledgeSingleMessage ¶
func (*Channel) BindExchangeToQueue ¶
func (*Channel) CancelConsumer ¶
func (*Channel) CommitTransaction ¶
func (*Channel) ConfigureChannelAsTransactional ¶
func (*Channel) ConfigureChannelBuffer ¶
func (*Channel) ConsumeWithoutAcknowledgement ¶
func (*Channel) DeclareExchange ¶
func (*Channel) DeclareQueue ¶
func (*Channel) DeclareTransientQueue ¶
func (*Channel) ExclusiveConsume ¶
func (*Channel) ExclusiveConsumeWithoutAcknowledgement ¶
func (*Channel) PublishMessage ¶
func (this *Channel) PublishMessage(destination, partition string, message amqp.Publishing) error
func (*Channel) RollbackTransaction ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func (*Connection) Close ¶
func (this *Connection) Close() error
Click to show internal directories.
Click to hide internal directories.