rabbitmq

package

v0.0.0-...-ed9d917 Latest Latest Go to latest Published: May 17, 2021 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/abecu-hub/go-bus

Links

Open Source Insights

Documentation ¶

Index ¶

func UseDefaultTopology(exchange string) func(*Transport)
func UsePriorityQueue(maxPriority uint8) func(*Transport)
type ConsumeSettings
type DefaultTopology
type Queue
type Topology
type Transport
- func Create(url string, options ...func(*Transport)) *Transport

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func UseDefaultTopology ¶

func UseDefaultTopology(exchange string) func(*Transport)

func UsePriorityQueue ¶

func UsePriorityQueue(maxPriority uint8) func(*Transport)

Types ¶

type ConsumeSettings ¶

type ConsumeSettings struct {
	Consumer  string
	AutoAck   bool
	Exclusive bool
	NoLocal   bool
	NoWait    bool
}

type DefaultTopology ¶

type DefaultTopology struct {
	Transport *Transport
	Exchange  string
}

func (*DefaultTopology) Publish ¶

func (t *DefaultTopology) Publish(msg *amqp.Publishing) error

func (*DefaultTopology) RegisterRouting ¶

func (t *DefaultTopology) RegisterRouting(route string) error

func (*DefaultTopology) Send ¶

func (t *DefaultTopology) Send(destination string, msg *amqp.Publishing) error

func (*DefaultTopology) SendLocal ¶

func (t *DefaultTopology) SendLocal(msg *amqp.Publishing) error

func (*DefaultTopology) Setup ¶

func (t *DefaultTopology) Setup() error

func (*DefaultTopology) UnregisterRouting ¶

func (t *DefaultTopology) UnregisterRouting(route string) error

type Queue ¶

type Queue struct {
	Name    string
	Durable bool
	AutoAck bool
	Args    amqp.Table
}

type Topology ¶

type Topology interface {
	Setup() error
	RegisterRouting(route string) error
	UnregisterRouting(route string) error
	Publish(msg *amqp.Publishing) error
	Send(destination string, msg *amqp.Publishing) error
	SendLocal(msg *amqp.Publishing) error
}

type Transport ¶

type Transport struct {
	Url        string
	InputQueue Queue
	// contains filtered or unexported fields
}

func Create ¶

func Create(url string, options ...func(*Transport)) *Transport

Create a new RabbitMQ Transport for the go-bus endpoint.

func (*Transport) GetConnection ¶

func (rmq *Transport) GetConnection() *amqp.Connection

func (*Transport) MessageReceived ¶

func (rmq *Transport) MessageReceived(eventChannel chan *servicebus.IncomingMessageContext) chan *servicebus.IncomingMessageContext

func (*Transport) Publish ¶

func (rmq *Transport) Publish(ctx *servicebus.OutgoingMessageContext) error

func (*Transport) RegisterRouting ¶

func (rmq *Transport) RegisterRouting(route string) error

func (*Transport) Send ¶

func (rmq *Transport) Send(destination string, ctx *servicebus.OutgoingMessageContext) error

func (*Transport) SendLocal ¶

func (rmq *Transport) SendLocal(ctx *servicebus.OutgoingMessageContext) error

func (*Transport) Start ¶

func (rmq *Transport) Start(endpointName string) error

func (*Transport) UnregisterRouting ¶

func (rmq *Transport) UnregisterRouting(route string) error

Source Files ¶

View all Source files

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