rabbitmq

Jun 6, 2023

Changes in this version

type RabbitMQ

+ func (r *RabbitMQ) Close() error

+ func (r *RabbitMQ) GetComponentMetadata() map[string]string

May 29, 2020

Changes in this version

+ type RabbitMQ struct

+ func NewRabbitMQ(logger logger.Logger) *RabbitMQ

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

+ func (r *RabbitMQ) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

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

+ func (r *RabbitMQ) Read(handler func(*bindings.ReadResponse) error) error