activemq

Documentation

Index

• func Close() error
• func Init() error
• func InitWithAddress(address string) error
• func InitWithUsernamePassword(address, username, password string) error
• func NewActiveMq() *activeMq
• func RegisterHandlers(queue string, handler func([]byte) error)
• func Send(queue string, data []byte, delay int64) error
• func SetAddresses(addresses ...string)
• func SetInsecureSkipVerify(insecureSkipVerify bool)
• func SetPassword(password string)
• func SetRecvCredit(credit uint32)
• func SetUsername(username string)
• func StartRead()

Functions

func Close

func Close() error

func Init

func Init() error

func InitWithAddress

func InitWithAddress(address string) error

func InitWithUsernamePassword

func InitWithUsernamePassword(address, username, password string) error

func NewActiveMq

func NewActiveMq() *activeMq

func RegisterHandlers

func RegisterHandlers(queue string, handler func([]byte) error)

func Send

func Send(queue string, data []byte, delay int64) error

func SetAddresses

func SetAddresses(addresses ...string)

func SetInsecureSkipVerify

func SetInsecureSkipVerify(insecureSkipVerify bool)

func SetPassword

func SetPassword(password string)

func SetRecvCredit

func SetRecvCredit(credit uint32)

func SetUsername

func SetUsername(username string)

func StartRead

func StartRead()