messagebroker

Documentation

Index

• type Consumer
• type MessageBroker
• type PostgresqlConnectionConfig
• type PostgresqlMessageBroker
  • func NewPostgresqlMessageBroker(config *PostgresqlConnectionConfig) (*PostgresqlMessageBroker, error)
  • func (e *PostgresqlMessageBroker) Consume(queue string, onMessage func(body []byte)) error
  • func (e *PostgresqlMessageBroker) Publish(routing string, body []byte) error
• type Publisher

Types

type Consumer

type Consumer interface {
	Consume(queue string, onMessage func(body []byte)) error
}

type MessageBroker

type MessageBroker interface {
	Publisher
	Consumer
}

type PostgresqlConnectionConfig

type PostgresqlConnectionConfig struct {
	Host     string // host (e.g. localhost) or path to unix domain socket directory (e.g. /private/tmp)
	Port     uint16 // default: 5432
	Database string
	User     string // default: OS user name
	Password string
}

type PostgresqlMessageBroker

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

func NewPostgresqlMessageBroker

func NewPostgresqlMessageBroker(config *PostgresqlConnectionConfig) (*PostgresqlMessageBroker, error)

func (*PostgresqlMessageBroker) Consume

func (e *PostgresqlMessageBroker) Consume(queue string, onMessage func(body []byte)) error

func (*PostgresqlMessageBroker) Publish

func (e *PostgresqlMessageBroker) Publish(routing string, body []byte) error

type Publisher

type Publisher interface {
	Publish(routing string, body []byte) error
}