activemq

README

activemq

This plugin collects queues and topics metrics using ActiveMQ Console API.

It produces following charts per queue and per topic:

1. Messages in messages/s

• enqueued
• dequeued
• unprocessed

1. Unprocessed Messages in messages

• unprocessed

1. Consumers in consumers

• consumers

configuration

Here is an example for 2 servers:

jobs:
  - name: job1
    url: http://127.0.0.1:8161
    webadmin: admin
    max_queues: 100
    max_topics: 100
    queues_filter: '!sandr* *'
    topics_filter: '!sandr* *'
    
  - name: remote
    url: http://100.127.0.1:8161
    webadmin: admin

Without configuration, module won't work.

---

Documentation

Index

• type Activemq
  • func New() *Activemq
  • func (a Activemq) Charts() *Charts
  • func (a *Activemq) Check() bool
  • func (Activemq) Cleanup()
  • func (a *Activemq) Collect() map[string]int64
  • func (a *Activemq) Init() bool
• type Charts
• type Dims

Types

type Activemq

type Activemq struct {
	modules.Base

	web.HTTP `yaml:",inline"`

	Webadmin     string `yaml:"webadmin"`
	MaxQueues    int    `yaml:"max_queues"`
	MaxTopics    int    `yaml:"max_topics"`
	QueuesFilter string `yaml:"queues_filter"`
	TopicsFilter string `yaml:"topics_filter"`
	// contains filtered or unexported fields
}

Activemq activemq module

func New

func New() *Activemq

New creates Example with default values

func (Activemq) Charts

func (a Activemq) Charts() *Charts

Charts creates Charts

func (*Activemq) Check

func (a *Activemq) Check() bool

Check makes check

func (Activemq) Cleanup

func (Activemq) Cleanup()

Cleanup makes cleanup

func (*Activemq) Collect

func (a *Activemq) Collect() map[string]int64

Collect collects metrics

func (*Activemq) Init

func (a *Activemq) Init() bool

Init makes initialization

type Charts

type Charts = modules.Charts

Charts is an alias for modules.Charts

type Dims

type Dims = modules.Dims

Dims is an alias for modules.Dims