Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.

rabbitmq

package

v1.8.0 Latest Latest Go to latest Published: Sep 3, 2026 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type RabbitMQQueueSource struct {
	// contains filtered or unexported fields
}

func NewRabbitMQQueueSource(url string, queueName string) (*RabbitMQQueueSource, error)

func (s *RabbitMQQueueSource) Ack(ctx context.Context, msg hermod.Message) error

func (s *RabbitMQQueueSource) Close() error

func (s *RabbitMQQueueSource) Ping(ctx context.Context) error

func (s *RabbitMQQueueSource) Read(ctx context.Context) (hermod.Message, error)

func (s *RabbitMQQueueSource) Sample(ctx context.Context, table string) (hermod.Message, error)

type RabbitMQStreamSource struct {
	// contains filtered or unexported fields
}

func NewRabbitMQStreamSource(url string, streamName string, consumerName string) (*RabbitMQStreamSource, error)

func (s *RabbitMQStreamSource) Ack(ctx context.Context, msg hermod.Message) error

func (s *RabbitMQStreamSource) Close() error

func (s *RabbitMQStreamSource) Ping(ctx context.Context) error

func (s *RabbitMQStreamSource) Read(ctx context.Context) (hermod.Message, error)

func (s *RabbitMQStreamSource) Sample(ctx context.Context, table string) (hermod.Message, error)