sendamqp

Documentation

Index

• type Sess
  • func New(amqpURL, amqpExchange, amqpRoutingKey, amqpTtl string) *Sess
  • func (sender *Sess) CloseSvc() error
  • func (sender *Sess) OpenSvc() error
  • func (sender *Sess) SendMessage(logEvent logevent.LogEvent) error
  • func (sender *Sess) SetTrace(v bool)

Types

type Sess

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

Sess stores sendamqp session state.

func New

func New(amqpURL, amqpExchange, amqpRoutingKey, amqpTtl string) *Sess

New creates a new sendhec object/session. It requires an AMQP URL/URI (which may contain username, password, host, port, and/or vhost), exchange name, and routing key.

func (*Sess) CloseSvc

func (sender *Sess) CloseSvc() error

CloseSvc closes the open session. CloseSvc must not be called when no session is open.

func (*Sess) OpenSvc

func (sender *Sess) OpenSvc() error

OpenSvc opens a new session. OpenSvc must not be called when a session is already open.

func (*Sess) SendMessage

func (sender *Sess) SendMessage(logEvent logevent.LogEvent) error

SendMessage sends a LogEvent to a RabbitMQ (AMQP) exchange.

func (*Sess) SetTrace

func (sender *Sess) SetTrace(v bool)

SetTrace enables tracing, which dumps all messages to stderr.