stomp_client

Documentation

Index

• type StompConsumer
  • func NewConsumer(cfg config.Config, id int) *StompConsumer
  • func (c *StompConsumer) Connect()
  • func (c *StompConsumer) Start(ctx context.Context, subscribed chan bool)
  • func (c *StompConsumer) Stop(reason string)
  • func (c *StompConsumer) Subscribe()
• type StompPublisher
  • func NewPublisher(cfg config.Config, id int) *StompPublisher
  • func (p *StompPublisher) Connect()
  • func (p *StompPublisher) Send() error
  • func (p *StompPublisher) Start(ctx context.Context)
  • func (p *StompPublisher) StartFullSpeed(ctx context.Context)
  • func (p *StompPublisher) StartIdle(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
	// contains filtered or unexported fields
}

func NewConsumer

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

func (*StompConsumer) Connect

func (c *StompConsumer) Connect()

func (*StompConsumer) Start

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

func (*StompConsumer) Stop

func (c *StompConsumer) Stop(reason string)

func (*StompConsumer) Subscribe

func (c *StompConsumer) Subscribe()

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) Connect

func (p *StompPublisher) Connect()

func (*StompPublisher) Send

func (p *StompPublisher) Send() error

func (*StompPublisher) Start

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

func (*StompPublisher) StartFullSpeed

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

func (*StompPublisher) StartIdle

func (p *StompPublisher) StartIdle(ctx context.Context)

func (*StompPublisher) StartRateLimited

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

func (*StompPublisher) Stop

func (p *StompPublisher) Stop(reason string)