Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultChannelPoolSize = 5 ExchangeType string = "topic" DefaultContentType string = "application/json" )
Variables ¶
This section is empty.
Functions ¶
func NewPublisher ¶
func NewPublisher( conn *amqp.Connection, opts ...publisher.OptionFunc, ) goqueue.Publisher
Types ¶
type ChannelPool ¶
type ChannelPool struct {
// contains filtered or unexported fields
}
func NewChannelPool ¶
func NewChannelPool(conn *amqp.Connection, maxSize int) *ChannelPool
func (*ChannelPool) Close ¶
func (cp *ChannelPool) Close() (err error)
func (*ChannelPool) Return ¶
func (cp *ChannelPool) Return(ch *amqp.Channel)
Source Files
Click to show internal directories.
Click to hide internal directories.