stomp_client

package

v0.1.2 Latest Latest Go to latest Published: Sep 28, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func (c StompConsumer) Start(subscribed chan bool)

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

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

func (p StompPublisher) Start()

func (p StompPublisher) StartFullSpeed()

func (p StompPublisher) StartRateLimited()