stomp

README

STOMP Producer Output Plugin

This plugin writes to a Active MQ Broker for STOMP http://stomp.github.io.

It also support Amazon MQ https://aws.amazon.com/amazon-mq/

Configuration

# Configuration for active mq with stomp protocol to send metrics to
[[outputs.stomp]]
  host = "localhost:61613"

  ## Queue name for producer messages
  queueName = "telegraf"

  ## Username and password if required by the Active MQ server.
  # username = ""
  # password = ""

  ## Optional TLS Config
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"

  ## Data format to output.
  data_format = "json"

Documentation

Index

• type STOMP
  • func (q *STOMP) Close() error
  • func (q *STOMP) Connect() error
  • func (q *STOMP) SampleConfig() string
  • func (q *STOMP) SetSerializer(serializer serializers.Serializer)
  • func (q *STOMP) Write(metrics []telegraf.Metric) error

Types

type STOMP

type STOMP struct {
	Host      string          `toml:"host"`
	Username  string          `toml:"username"`
	Password  string          `toml:"password"`
	QueueName string          `toml:"queueName"`
	Log       telegraf.Logger `toml:"-"`

	HeartBeatSend config.Duration `toml:"heartbeat_timeout_send"`
	HeartBeatRec  config.Duration `toml:"heartbeat_timeout_receive"`

	commontls.ClientConfig
	// contains filtered or unexported fields
}

func (*STOMP) Close

func (q *STOMP) Close() error

func (*STOMP) Connect

func (q *STOMP) Connect() error

func (*STOMP) SampleConfig

func (q *STOMP) SampleConfig() string

func (*STOMP) SetSerializer

func (q *STOMP) SetSerializer(serializer serializers.Serializer)

func (*STOMP) Write

func (q *STOMP) Write(metrics []telegraf.Metric) error