Documentation
¶
Index ¶
- type IBMMq
- func (mq IBMMq) Close()
- func (mq *IBMMq) GetInput(dest string, params ...string) (result jms20subset.JMSConsumer, err error)
- func (mq *IBMMq) GetOutput() *lib.ProducerImpl
- func (mq *IBMMq) GetQueueByName(dest string) jms20subset.Queue
- func (mq *IBMMq) Init() error
- func (mq *IBMMq) Open() (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) GetInput ¶
func (mq *IBMMq) GetInput(dest string, params ...string) (result jms20subset.JMSConsumer, err error)
GetInput - get input
func (*IBMMq) GetQueueByName ¶ added in v1.0.2
func (mq *IBMMq) GetQueueByName(dest string) jms20subset.Queue
GetQueueByName - get queue by name
Click to show internal directories.
Click to hide internal directories.