artemis

Documentation

Index

• Constants
• func GetCreationError(jdata *jolokia.ResponseData) string
• type Artemis
  • func GetArtemis(_ip string, _jolokiaPort string, _name string, _user string, _password string, ...) *Artemis
  • func NewArtemis(_ip string, _jolokiaPort string, _name string, _user string, _password string) *Artemis
  • func (artemis *Artemis) CreateAddress(addressName string, routingType string) (*jolokia.ResponseData, error)
  • func (artemis *Artemis) CreateQueue(addressName string, queueName string, routingType string) (*jolokia.ResponseData, error)
  • func (artemis *Artemis) CreateQueueFromConfig(queueConfig string, ignoreIfExists bool) (*jolokia.ResponseData, error)
  • func (artemis *Artemis) DeleteAddress(addressName string) (*jolokia.ResponseData, error)
  • func (artemis *Artemis) DeleteQueue(queueName string) (*jolokia.ResponseData, error)
  • func (artemis *Artemis) GetStatus() (string, error)
  • func (artemis *Artemis) ListBindingsForAddress(addressName string) (*jolokia.ResponseData, error)
  • func (artemis *Artemis) UpdateQueue(queueConfig string) (*jolokia.ResponseData, error)
  • func (artemis *Artemis) Uptime() (*jolokia.ResponseData, error)
• type IArtemis

Constants

const (
	QUEUE_ALREADY_EXISTS   = "AMQ229019"
	ADDRESS_ALREADY_EXISTS = "AMQ229204"
	UNKNOWN_ERROR          = "AMQ_UNKNOWN"
)

Functions

func GetCreationError

func GetCreationError(jdata *jolokia.ResponseData) string

Types

type Artemis

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

func GetArtemis

func GetArtemis(_ip string, _jolokiaPort string, _name string, _user string, _password string, _protocol string) *Artemis

func NewArtemis

func NewArtemis(_ip string, _jolokiaPort string, _name string, _user string, _password string) *Artemis

func (*Artemis) CreateAddress

func (artemis *Artemis) CreateAddress(addressName string, routingType string) (*jolokia.ResponseData, error)

func (*Artemis) CreateQueue

func (artemis *Artemis) CreateQueue(addressName string, queueName string, routingType string) (*jolokia.ResponseData, error)

func (*Artemis) CreateQueueFromConfig

func (artemis *Artemis) CreateQueueFromConfig(queueConfig string, ignoreIfExists bool) (*jolokia.ResponseData, error)

func (*Artemis) DeleteAddress

func (artemis *Artemis) DeleteAddress(addressName string) (*jolokia.ResponseData, error)

func (*Artemis) DeleteQueue

func (artemis *Artemis) DeleteQueue(queueName string) (*jolokia.ResponseData, error)

func (*Artemis) GetStatus

func (artemis *Artemis) GetStatus() (string, error)

func (*Artemis) ListBindingsForAddress

func (artemis *Artemis) ListBindingsForAddress(addressName string) (*jolokia.ResponseData, error)

func (*Artemis) UpdateQueue

func (artemis *Artemis) UpdateQueue(queueConfig string) (*jolokia.ResponseData, error)

func (*Artemis) Uptime

func (artemis *Artemis) Uptime() (*jolokia.ResponseData, error)

type IArtemis

type IArtemis interface {
	NewArtemis(_ip string, _jolokiaPort string, _name string, _userName string, _password string) *Artemis
	Uptime() (*jolokia.ResponseData, error)
	CreateQueue(addressName string, queueName string) (*jolokia.ResponseData, error)
	DeleteQueue(queueName string) (*jolokia.ResponseData, error)
	ListBindingsForAddress(addressName string) (*jolokia.ResponseData, error)
	DeleteAddress(addressName string) (*jolokia.ResponseData, error)
	CreateQueueFromConfig(queueConfig string, ignoreIfExists bool) (jolokia.ResponseData, error)
	UpdateQueue(queueConfig string) (jolokia.ResponseData, error)
}