stomp_client

Documentation

Index

• type StompConsumer
  • func NewConsumer(cfg config.Config, id int) *StompConsumer
  • func (c StompConsumer) Start(ctx context.Context, subscribed chan bool)
  • func (c StompConsumer) Stop(reason string)
• type StompPublisher
  • func NewPublisher(cfg config.Config, id int) *StompPublisher
  • func (p StompPublisher) Send()
  • func (p StompPublisher) Start(ctx context.Context)
  • func (p StompPublisher) StartFullSpeed(ctx context.Context)
  • func (p StompPublisher) StartRateLimited(ctx context.Context)
  • func (p StompPublisher) Stop(reason string)

Types

type StompConsumer

type StompConsumer struct {
	Id           int
	Connection   *stomp.Conn
	Subscription *stomp.Subscription
	Topic        string
	Config       config.Config
}

func NewConsumer

func NewConsumer(cfg config.Config, id int) *StompConsumer

func (StompConsumer) Start

func (c StompConsumer) Start(ctx context.Context, subscribed chan bool)

func (StompConsumer) Stop

func (c StompConsumer) Stop(reason string)

type StompPublisher

type StompPublisher struct {
	Id         int
	Connection *stomp.Conn
	Topic      string
	Config     config.Config
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(cfg config.Config, id int) *StompPublisher

func (StompPublisher) Send

func (p StompPublisher) Send()

func (StompPublisher) Start

func (p StompPublisher) Start(ctx context.Context)

func (StompPublisher) StartFullSpeed

func (p StompPublisher) StartFullSpeed(ctx context.Context)

func (StompPublisher) StartRateLimited

func (p StompPublisher) StartRateLimited(ctx context.Context)

func (StompPublisher) Stop

func (p StompPublisher) Stop(reason string)