artemis

package

v1.0.16 Latest Latest Go to latest Published: Nov 22, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

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
type IArtemis

Constants ¶

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

Variables ¶

This section is empty.

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)
}

Source Files ¶

View all Source files

artemis.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL