messaging

Documentation

Index

• type MessageBroker
  • func (mb *MessageBroker) CloseConnection()
  • func (mb *MessageBroker) DeSubscribeAsync(topic string)
  • func (mb *MessageBroker) Publish(topic string, payload []byte)
  • func (mb *MessageBroker) PublishRequestAndWait(topic string, payload []byte, timeout time.Duration) (*nats.Msg, error)
  • func (mb *MessageBroker) StartMessageBrokerConnection(servicename string)
  • func (mb *MessageBroker) SubscribeAsync(topic string, callback nats.MsgHandler)
  • func (mb *MessageBroker) SubscribeQueueAsync(topic string, queue string, callback nats.MsgHandler)

Types

type MessageBroker

type MessageBroker struct {
	URL      string
	Username string
	Password string

	NatsConnection *nats.Conn
	// contains filtered or unexported fields
}

func (*MessageBroker) CloseConnection

func (mb *MessageBroker) CloseConnection()

func (*MessageBroker) DeSubscribeAsync

func (mb *MessageBroker) DeSubscribeAsync(topic string)

func (*MessageBroker) Publish

func (mb *MessageBroker) Publish(topic string, payload []byte)

func (*MessageBroker) PublishRequestAndWait

func (mb *MessageBroker) PublishRequestAndWait(topic string, payload []byte, timeout time.Duration) (*nats.Msg, error)

func (*MessageBroker) StartMessageBrokerConnection

func (mb *MessageBroker) StartMessageBrokerConnection(servicename string)

func (*MessageBroker) SubscribeAsync

func (mb *MessageBroker) SubscribeAsync(topic string, callback nats.MsgHandler)

func (*MessageBroker) SubscribeQueueAsync

func (mb *MessageBroker) SubscribeQueueAsync(topic string, queue string, callback nats.MsgHandler)