ibmmq

README

ibmmq

Documentation

Index

• type IBMMq
  • func (mq IBMMq) Close()
  • func (mq *IBMMq) Context() *lib.ContextImpl
  • func (mq *IBMMq) GetInput(dest string, params ...string) (result *lib.ConsumerImpl, err error)
  • func (mq *IBMMq) GetOutput() *lib.ProducerImpl
  • func (mq *IBMMq) GetQueueByName(dest string) *lib.QueueImpl
  • func (mq *IBMMq) Init() error
  • func (mq *IBMMq) Open() (err error)

Types

type IBMMq

type IBMMq struct {
	QMName   *string `yaml:"qmName"`
	Host     string  `yaml:"host"`
	Port     *int    `yaml:"port"`
	User     string  `yaml:"user"`
	Password string  `yaml:"password"`
	Channel  string  `yaml:"channel"`
	// contains filtered or unexported fields
}

IBMMq - ibm-mq configuration and provide streams

func (IBMMq) Close

func (mq IBMMq) Close()

Close - close connection

func (*IBMMq) Context

func (mq *IBMMq) Context() *lib.ContextImpl

func (*IBMMq) GetInput

func (mq *IBMMq) GetInput(dest string, params ...string) (result *lib.ConsumerImpl, err error)

GetInput - get input

func (*IBMMq) GetOutput

func (mq *IBMMq) GetOutput() *lib.ProducerImpl

GetOutput - get output

func (*IBMMq) GetQueueByName

func (mq *IBMMq) GetQueueByName(dest string) *lib.QueueImpl

GetQueueByName - get queue by name

func (*IBMMq) Init

func (mq *IBMMq) Init() error

Init - initialize properties

func (*IBMMq) Open

func (mq *IBMMq) Open() (err error)

Open - open connection