distributed

package
v0.0.0-...-e51d946 Latest Latest
Warning

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

 Go to latest Published: Nov 23, 2019 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Package distributed interactions with AMQP RabbitMQ

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PublishBody 

func PublishBody(data []byte) amqp.Publishing

PublishBody return publish object

Types

type Client 

type Client struct {
	Channel *amqp.Channel
	Queue   amqp.Queue
}

Client general for AMQP

func NewDistributed 

func NewDistributed(brokerURL string, queueName string) *Client

NewDistributed create a distributed client for general use brokerURL: broker to connect, queueName: queue to publish to

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.