messanger

package module
v0.0.0-...-f55a6fa Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 5, 2022 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Messanger

type Messanger struct {
	AmpqUri            string
	ListeningQueueUri  string
	RespondingQueueUri string
	ListeningQueue     *amqp.Queue
	RespondingQueue    *amqp.Queue
	// contains filtered or unexported fields
}

func NewMessanger

func NewMessanger(ampqUri string, listeningQueueUri string, respondingQueueUri string) *Messanger

func (*Messanger) Close

func (m *Messanger) Close() error

func (*Messanger) Connect

func (m *Messanger) Connect() error

func (*Messanger) DeclareListeningQueue

func (m *Messanger) DeclareListeningQueue() error

func (*Messanger) DeclareRespondingQueue

func (m *Messanger) DeclareRespondingQueue() error

func (*Messanger) Listen

func (m *Messanger) Listen() (<-chan amqp.Delivery, error)

func (*Messanger) Respond

func (m *Messanger) Respond(msg string) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL