nats

Documentation

Index

• type MessageQueue
  • func NewMessageQueue(conn string) *MessageQueue
  • func (s *MessageQueue) Publish(subj string, ch chan []byte)
  • func (s *MessageQueue) Subscribe(subj, queueName string, ch chan *nats.Msg) (*nats.Subscription, error)

Types

type MessageQueue

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

MessageQueue ...

func NewMessageQueue

func NewMessageQueue(conn string) *MessageQueue

NewMessageQueue ...

func (*MessageQueue) Publish

func (s *MessageQueue) Publish(subj string, ch chan []byte)

Publish ...

func (*MessageQueue) Subscribe

func (s *MessageQueue) Subscribe(subj, queueName string, ch chan *nats.Msg) (*nats.Subscription, error)

Subscribe ...