httppublisher

Documentation

Index

• Constants
• type Publisher
  • func New(serviceName string, t httpTransport) *Publisher
  • func (p *Publisher) Close() error
  • func (p *Publisher) Publish(topic string, messages ...*message.Message) error

Constants

const MetadataSendTo = "send_to"

MetadataSendTo is the metadata key for the destination URL.

Types

type Publisher

type Publisher struct {
	*lifecycle.Lifecycle

	ServiceName string
	// contains filtered or unexported fields
}

Publisher is an implementation of a Watermill Publisher that publishes messages over HTTP.

func New

func New(serviceName string, t httpTransport) *Publisher

New creates a new HTTP Publisher.

func (*Publisher) Close

func (p *Publisher) Close() error

Close closes the publisher.

func (*Publisher) Publish

func (p *Publisher) Publish(topic string, messages ...*message.Message) error

Publish publishes the messages over HTTP to the destination specified in the messages 'send-to' metadata.