mq

Documentation

Index

• type Client
  • func NewClient(cfg *Config) (*Client, error)
• type Config

Types

type Client

type Client struct {

	// Message queue AMQP endpoint
	Endpoint string
	// Connection to a STOMP server
	Connection *stomp.Conn
	// Message queue service
	MessageQueue *messageQueueService
	// contains filtered or unexported fields
}

Client is the top-level interface for the RMQ

func NewClient

func NewClient(cfg *Config) (*Client, error)

NewClient initializes the RMQ Client

type Config

type Config struct {
	// Message queue username
	Username string
	// Message queue password
	Password string
	// Message queue topic
	ClientID string
	// Rize infrastructure target environment. Defaults to `sandbox“
	Environment string
	// Enable debug logging
	Debug bool
}

Config stores RMQ configuration values