activeMQ

README

go-activeMQ

activeMQ client for go based on github.com/go-stomp/stomp

usage:

//Send
if err := utils.NewActiveMQ("localhost:61613").Send("/queue/test-1", "test from 1"); err != nil {
    fmt.Println("AMQ ERROR:", err)

//this func will handle the messges get from activeMQ server.
handler := func(err error, msg string) { fmt.Println("AMQ MSG:", err, msg) }
if err := utils.NewActiveMQ("localhost:61613").Subscribe("/queue/test-1", handler); err != nil {
    fmt.Println("AMQ ERROR:", err)
}

Contact Me:

Email:anjieych@126.com QQ: 272348197

Documentation

Overview

Usage:

	//Send
	if err := utils.NewActiveMQ("localhost:61613").Send("/queue/test-1", "test from 1"); err != nil {
	fmt.Println("AMQ ERROR:", err)

 //this func will handle the messges get from activeMQ server.
	handler := func(err error, msg string) { fmt.Println("AMQ MSG:", err, msg) }
	if err := utils.NewActiveMQ("localhost:61613").Subscribe("/queue/test-1", handler); err != nil {
	  fmt.Println("AMQ ERROR:", err)
	}

Index

• type ActiveMQ
  • func NewActiveMQ(addr string) *ActiveMQ
  • func (this *ActiveMQ) Check() error
  • func (this *ActiveMQ) Connect() (*stomp.Conn, error)
  • func (this *ActiveMQ) Send(destination string, msg string) error
  • func (this *ActiveMQ) Subscribe(destination string, handler func(err error, msg string)) error

Types

type ActiveMQ

type ActiveMQ struct {
	Addr string
}

func NewActiveMQ

func NewActiveMQ(addr string) *ActiveMQ

New activeMQ with addr[eg:localhost:61613] as host address.

func (*ActiveMQ) Check

func (this *ActiveMQ) Check() error

Used for health check

func (*ActiveMQ) Connect

func (this *ActiveMQ) Connect() (*stomp.Conn, error)

Connect to activeMQ

func (*ActiveMQ) Send

func (this *ActiveMQ) Send(destination string, msg string) error

Send msg to destination

func (*ActiveMQ) Subscribe

func (this *ActiveMQ) Subscribe(destination string, handler func(err error, msg string)) error

Subscribe Message from destination func handler handle msg reveived from destination