amqp

Documentation

Overview

Package amqp implements an inbound DIDComm transport for Aries (aries-framework-go).

Index

• type Inbound
  • func NewInbound(amqpServerURL, externalAddr, queueName, certFile, keyFile string) (*Inbound, error)
  • func (i *Inbound) Endpoint() string
  • func (i *Inbound) Start(prov transport.Provider) error
  • func (i *Inbound) Stop() error

Types

type Inbound

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

Inbound amqp type.

func NewInbound

func NewInbound(amqpServerURL, externalAddr, queueName, certFile, keyFile string) (*Inbound, error)

NewInbound creates a new AMQP inbound transport instance.

func (*Inbound) Endpoint

func (i *Inbound) Endpoint() string

Endpoint provides the AMQP connection details.

func (*Inbound) Start

func (i *Inbound) Start(prov transport.Provider) error

Start the AMQP message loop.

func (*Inbound) Stop

func (i *Inbound) Stop() error

Stop the AMQP message loop.