rabbitmq

package

v1.8.0-rc.3 Latest Latest Go to latest Published: Jun 22, 2022 License: Apache-2.0 Imports: 10 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

RabbitMQ allows sending/receiving data to/from RabbitMQ.

func NewRabbitMQ(logger logger.Logger) *RabbitMQ

NewRabbitMQ returns a new rabbitmq instance.

func (r *RabbitMQ) Init(metadata bindings.Metadata) error

Init does metadata parsing and connection creation.

func (r *RabbitMQ) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (r *RabbitMQ) Operations() []bindings.OperationKind

func (r *RabbitMQ) Read(handler bindings.Handler) error