go_jolokia_test.go

// Maintainer Swarvanu Sengupta <swarvanusg@gmail.com>.
//
// Use of this source code is governed by an MIT-style
// license that can be found in the LICENSE file.
package go_jolokia

import "testing"
import "fmt"

// Note that these test currently expect a jolokia java process to be
// running on 7025. Currently tested with a cassandra process2

var (
	host       = "localhost"
	port       = "8080"
	jolokia    = "jolokia-war-1.2.3"
	targetHost = "localhost"
	targetPort = "9999"
)

func TestClientExecuteOperation(t *testing.T) {
	client := NewJolokiaClient("http://" + host + ":" + port + "/" + jolokia)
	client.SetTarget(targetHost + ":" + targetPort)
	result, err := client.ExecuteOperation("java.lang:type=Threading", "getThreadInfo([J,boolean,boolean)",
		[]interface{}{[]int{153, 263}, true, true}, "")
	if err != nil {
		t.Errorf("err(%s) returned", err)
	}
	fmt.Println("Operation result: ", result)
}

func TestClientListDomainsOverridingInternalUrl(t *testing.T) {
	client := NewJolokiaClient("http://" + host + ":" + port + "/" + jolokia)
	client.SetTarget("service:jmx:rmi:///jndi/rmi://" + targetHost + ":" + targetPort + "/jmxrmi")
	domains, err := client.ListDomains()
	if err != nil {
		t.Errorf("err(%s) returned", err)
	}
	fmt.Println("Domains: ", domains)
}

func TestClientListDomains(t *testing.T) {
	client := NewJolokiaClient("http://" + host + ":" + port + "/" + jolokia)
	client.SetTarget(targetHost + ":" + targetPort)
	domains, err := client.ListDomains()
	if err != nil {
		t.Errorf("err(%s) returned", err)
	}
	fmt.Println("Domains: ", domains)
}

func TestClientListBeans(t *testing.T) {
	client := NewJolokiaClient("http://" + host + ":" + port + "/" + jolokia)
	client.SetTarget(targetHost + ":" + targetPort)
	beans, err := client.ListBeans("java.lang")
	if err != nil {
		t.Errorf("err(%s) returned", err)
	}
	fmt.Println("Beans: ", beans)
}

func TestClientListProperties(t *testing.T) {
	client := NewJolokiaClient("http://" + host + ":" + port + "/" + jolokia)
	client.SetTarget(targetHost + ":" + targetPort)
	props, err := client.ListProperties("java.lang", []string{"type=Threading"})
	if err != nil {
		t.Errorf("err(%s), returned", err)
	}
	fmt.Println("Properties: ", props)
}

func TestClientGetAttr(t *testing.T) {
	client := NewJolokiaClient("http://" + host + ":" + port + "/" + jolokia)
	client.SetTarget(targetHost + ":" + targetPort)
	val, err := client.GetAttr("java.lang", []string{"type=Threading"}, "PeakThreadCount")
	if err != nil {
		t.Errorf("err(%s), returned", err)
		return
	}
	fmt.Println("Value:", val)
}