amqputils

package module

v1.5.0 Latest Latest Go to latest Published: Nov 15, 2019 License: MIT Imports: 6 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/mrkaspa/amqputils

Links

Open Source Insights

Documentation ¶

Overview ¶

Package amqputils is a library for creating easily client and a amqp servers

Index ¶

Variables
func Call(url, queueName string, info []byte, poolSize int) ([]byte, error)
func CallWithConn(ch *amqp.Channel, queueName string, info []byte, poolSize int) ([]byte, error)
func CallWithConnAsync(ch *amqp.Channel, queueName string, info []byte, resp chan []byte, ...) error
func CreateChannelConnection(url string) (*amqp.Channel, func(), error)
func CreateConnection(url string) (*amqp.Connection, *amqp.Channel, func(), error)
func CreateQueue(ch *amqp.Channel, queueName string) (*amqp.Queue, error)
func CreateQueueNotDurable(ch *amqp.Channel, queueName string) (*amqp.Queue, error)
func Publish(url, queueName string, info []byte) error
func PublishWithConn(ch *amqp.Channel, queueName string, info []byte) error
func Subscribe(ch *amqp.Channel, q *amqp.Queue, do SubscribeFunc, poolConSize int) error
type Server
- func HealtCheck(ch *amqp.Channel, queueService string) (*Server, error)
- func NewServer(ch *amqp.Channel, event string, do SubscribeFunc, poolSize int) (*Server, error)
- func (s *Server) Start()
type SubscribeFunc
type TunnyExecutor

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrTimeout = errors.New("timeout error")

ErrTimeout error

Functions ¶

func Call ¶

func Call(url, queueName string, info []byte, poolSize int) ([]byte, error)

Call a queue and receives the response

func CallWithConn ¶

func CallWithConn(ch *amqp.Channel, queueName string, info []byte, poolSize int) ([]byte, error)

CallWithConn a queue and receives the response

func CallWithConnAsync ¶

func CallWithConnAsync(ch *amqp.Channel, queueName string, info []byte, resp chan []byte, poolSize int) error

CallWithConnAsync a queue and receives the response in a channel

func CreateChannelConnection ¶

func CreateChannelConnection(url string) (*amqp.Channel, func(), error)

CreateChannelConnection channel and its respective close function

func CreateConnection ¶

func CreateConnection(url string) (*amqp.Connection, *amqp.Channel, func(), error)

CreateConnection connection - channel and its respective close function

func CreateQueue ¶

func CreateQueue(ch *amqp.Channel, queueName string) (*amqp.Queue, error)

CreateQueue in the amqp server

func CreateQueueNotDurable ¶

func CreateQueueNotDurable(ch *amqp.Channel, queueName string) (*amqp.Queue, error)

CreateQueueNotDurable in the amqp server not durable

func Publish ¶

func Publish(url, queueName string, info []byte) error

Publish in a queue

func PublishWithConn ¶

func PublishWithConn(ch *amqp.Channel, queueName string, info []byte) error

PublishWithConn in a queue

func Subscribe(ch *amqp.Channel, q *amqp.Queue, do SubscribeFunc, poolConSize int) error

Subscribe to a queue and handle the messages

Types ¶

type Server ¶

type Server struct {
	Event     string
	Do        SubscribeFunc
	AMQPChan  *amqp.Channel
	AMQPQueue *amqp.Queue
	PoolSize  int
}

Server for receiving amqp messages

func HealtCheck ¶

func HealtCheck(ch *amqp.Channel, queueService string) (*Server, error)

HealtCheck send a response each time that receive a message

func NewServer ¶

func NewServer(ch *amqp.Channel, event string, do SubscribeFunc, poolSize int) (*Server, error)

NewServer creates one

func (*Server) Start ¶

func (s *Server) Start()

Start the server

type SubscribeFunc ¶

type SubscribeFunc func(amqp.Delivery) ([]byte, error)

SubscribeFunc function to handle an incoming message

type TunnyExecutor ¶ added in v1.5.0

type TunnyExecutor struct {
	Do       SubscribeFunc
	AMQPChan *amqp.Channel
	Delivery amqp.Delivery
}

TunnyExecutor pool args

Source Files ¶

View all Source files

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