gousustomp

Documentation

Index

• Constants
• func NewService(ctx gousu.IContext) gousu.IService
• type IService
• type Service
  • func (s *Service) Ack(msg *stomp.Message) error
  • func (s *Service) Health() error
  • func (s *Service) Name() string
  • func (s *Service) PublishToQueue(queue string, contentType string, body []byte) error
  • func (s *Service) Start() error
  • func (s *Service) Stop() error
  • func (s *Service) SubscribeToQueue(queue string) (chan *stomp.Message, *stomp.Subscription, error)

Constants

const ServiceName = "stomp"

Functions

func NewService

func NewService(ctx gousu.IContext) gousu.IService

Types

type IService

type IService interface {
	gousu.IService

	SubscribeToQueue(queue string) (chan *stomp.Message, *stomp.Subscription, error)
	Ack(msg *stomp.Message) error
	PublishToQueue(queue string, contentType string, body []byte) error
}

type Service

type Service struct {
	// contains filtered or unexported fields
}

func (*Service) Ack

func (s *Service) Ack(msg *stomp.Message) error

func (*Service) Health

func (s *Service) Health() error

func (*Service) Name

func (s *Service) Name() string

func (*Service) PublishToQueue

func (s *Service) PublishToQueue(queue string, contentType string, body []byte) error

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error

func (*Service) SubscribeToQueue

func (s *Service) SubscribeToQueue(queue string) (chan *stomp.Message, *stomp.Subscription, error)