Documentation ¶
Index ¶
- type RabbitmqChannelManager
- func (m *RabbitmqChannelManager) Close() error
- func (m *RabbitmqChannelManager) IsQueueExist(queueName string) bool
- func (m *RabbitmqChannelManager) Iterator() (<-chan types.RabbitmqMessage, error)
- func (m *RabbitmqChannelManager) OnReconnect() error
- func (m *RabbitmqChannelManager) QueueFrom() string
- func (m *RabbitmqChannelManager) Send(sendQueue string, payload interface{}, messageID string, correlationID string, ...) error
- func (m *RabbitmqChannelManager) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitmqChannelManager ¶
type RabbitmqChannelManager struct {
// contains filtered or unexported fields
}
func CreateChannelManager ¶
func CreateChannelManager(r rabbitmqClient, queueFrom string, prefetchCount int) (*RabbitmqChannelManager, error)
func (*RabbitmqChannelManager) Close ¶
func (m *RabbitmqChannelManager) Close() error
func (*RabbitmqChannelManager) IsQueueExist ¶
func (m *RabbitmqChannelManager) IsQueueExist(queueName string) bool
func (*RabbitmqChannelManager) Iterator ¶
func (m *RabbitmqChannelManager) Iterator() (<-chan types.RabbitmqMessage, error)
func (*RabbitmqChannelManager) OnReconnect ¶
func (m *RabbitmqChannelManager) OnReconnect() error
func (*RabbitmqChannelManager) QueueFrom ¶
func (m *RabbitmqChannelManager) QueueFrom() string
func (*RabbitmqChannelManager) Stop ¶
func (m *RabbitmqChannelManager) Stop() error
Click to show internal directories.
Click to hide internal directories.