natsmsgqueue

Documentation

Index

• type MSGQueue
  • func New(ctx context.Context, uri, subject string) (*MSGQueue, error)
  • func (mq *MSGQueue) Publish(data []byte) error
  • func (mq *MSGQueue) Subscribe(h handler.MSGHandlerFunc) error

Types

type MSGQueue

type MSGQueue struct {
	Host string
	// contains filtered or unexported fields
}

MSGQueue defines a messaging queue handled by the NATS server.

func New

func New(ctx context.Context, uri, subject string) (*MSGQueue, error)

New creates and opens a NATS messaging queue connection.

func (*MSGQueue) Publish

func (mq *MSGQueue) Publish(data []byte) error

Publish publishes a message to the specified subject.

func (*MSGQueue) Subscribe

func (mq *MSGQueue) Subscribe(h handler.MSGHandlerFunc) error

Subscribe opens a subscriber to the specified subject. Incoming messages will be forwarded to the handler. This will block until NATS's context ends.