stomp

Documentation

Index

• type StompConsumer
  • func NewConsumer(ctx context.Context, cfg config.Config, id int) *StompConsumer
  • func (c *StompConsumer) Connect()
  • func (c *StompConsumer) Start(consumerReady chan bool)
  • func (c *StompConsumer) Stop(reason string)
  • func (c *StompConsumer) Subscribe()
• type StompPublisher
  • func NewPublisher(ctx context.Context, cfg config.Config, id int) *StompPublisher
  • func (p *StompPublisher) Connect()
  • func (p *StompPublisher) Send() error
  • func (p *StompPublisher) Start(publisherReady chan bool, startPublishing chan bool)
  • func (p *StompPublisher) StartPublishing() string
  • 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(ctx context.Context, cfg config.Config, id int) *StompConsumer

func (*StompConsumer) Connect

func (c *StompConsumer) Connect()

func (*StompConsumer) Start

func (c *StompConsumer) Start(consumerReady 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(ctx context.Context, 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(publisherReady chan bool, startPublishing chan bool)

func (*StompPublisher) StartPublishing

func (p *StompPublisher) StartPublishing() string

func (*StompPublisher) Stop

func (p *StompPublisher) Stop(reason string)