package
Version:
v0.12.2
Opens a new window with list of versions in this module.
Published: Apr 5, 2022
License: MIT
Opens a new window with license information.
Imports: 4
Opens a new window with list of imports.
Imported by: 3
Opens a new window with list of known importers.
Documentation
¶
Package rabbitmq is a wrapper of the original "github.com/streadway/amqp" library.
Only contains basic publish, subscribe, and close methods.
Data will be encoded to JSON before publishing the message.
Channel is rabbitmq subscription channel.
Close to close subscription.
func (c *Channel) Read(model interface{}) (<-chan interface{}, <-chan error)
Read to read incoming message.
Client is rabbitmq pubsub client.
New to create new rabbitmq pubsub client.
Close to close pubsub connection.
Publish to publish message.
Subscribe to subscribe queue.
Need to convert the return type to fairy.Channel.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.