rabbitmq

Documentation

Index

• Constants
• type Client
  • func NewClient(messageBusURI string) *Client
  • func (c *Client) Close(ctx context.Context) error
  • func (c *Client) Connect(ctx context.Context) error
  • func (c *Client) Publish(ctx context.Context, routingKey string, req interface{}) error
• type ClientInterface

Constants

const (
	ExchangeName              = ""
	QueueNameBeginTransaction = "begin_transaction"
	QueueNameEndTransaction   = "end_transaction"
)

Client-specific constants

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is the RabbitMQ client object

func NewClient

func NewClient(messageBusURI string) *Client

NewClient initializes a new HEP processor

func (*Client) Close

func (c *Client) Close(ctx context.Context) error

Close closes the client to the message bus

func (*Client) Connect

func (c *Client) Connect(ctx context.Context) error

Connect connects the client to the message bus

func (*Client) Publish

func (c *Client) Publish(ctx context.Context, routingKey string, req interface{}) error

Publish publishes a message in the message bus

type ClientInterface

type ClientInterface interface {
	Connect(ctx context.Context) error
	Close(ctx context.Context) error
	Publish(ctx context.Context, routingKey string, req interface{}) error
}

ClientInterface is the interface for RabbitMQ client objects