mqjms

May 11, 2025

Changes in this version

+ func CreateJMSExceptionFromMQReturn(mqretError error, datalen int) jms20subset.JMSException

type ConnectionFactoryImpl

+ AcceptTruncatedMessage bool

Mar 23, 2022

Changes in this version

type MessageImpl

+ func (msg *MessageImpl) GetJMSExpiration() int64

+ func (msg *MessageImpl) GetJMSPriority() int

type ProducerImpl

+ func (producer *ProducerImpl) GetPriority() int

+ func (producer *ProducerImpl) SetPriority(priority int) jms20subset.JMSProducer

Feb 12, 2022

Changes in this version

+ type BrowserImpl struct

+ func (browser *BrowserImpl) GetEnumeration() (jms20subset.MessageIterator, jms20subset.JMSException)

+ func (browser *BrowserImpl) GetNext() (jms20subset.Message, jms20subset.JMSException)

type ContextImpl

+ func (ctx ContextImpl) CreateBrowser(dest jms20subset.Destination) (jms20subset.QueueBrowser, jms20subset.JMSException)

Jan 2, 2022

Changes in this version

+ const MessageImpl_PROPERTY_CONVERT_FAILED_CODE

+ const MessageImpl_PROPERTY_CONVERT_FAILED_REASON

+ const MessageImpl_PROPERTY_CONVERT_NOTSUPPORTED_CODE

+ const MessageImpl_PROPERTY_CONVERT_NOTSUPPORTED_REASON

type MessageImpl

+ func (msg *MessageImpl) ClearProperties() jms20subset.JMSException

+ func (msg *MessageImpl) GetBooleanProperty(name string) (bool, jms20subset.JMSException)

+ func (msg *MessageImpl) GetDoubleProperty(name string) (float64, jms20subset.JMSException)

+ func (msg *MessageImpl) GetIntProperty(name string) (int, jms20subset.JMSException)

+ func (msg *MessageImpl) GetPropertyNames() ([]string, jms20subset.JMSException)

+ func (msg *MessageImpl) GetStringProperty(name string) (*string, jms20subset.JMSException)

+ func (msg *MessageImpl) PropertyExists(name string) (bool, jms20subset.JMSException)

+ func (msg *MessageImpl) SetBooleanProperty(name string, value bool) jms20subset.JMSException

+ func (msg *MessageImpl) SetDoubleProperty(name string, value float64) jms20subset.JMSException

+ func (msg *MessageImpl) SetIntProperty(name string, value int) jms20subset.JMSException

+ func (msg *MessageImpl) SetStringProperty(name string, value *string) jms20subset.JMSException

Aug 17, 2021

Changes in this version

+ const ContextImpl_TRANSACTED_ASYNCPUT_ACTIVE

type ConnectionFactoryImpl

+ SendCheckCount int

type QueueImpl

+ func (queue QueueImpl) GetPutAsyncAllowed() int

+ func (queue QueueImpl) SetPutAsyncAllowed(paa int) jms20subset.Queue

Feb 10, 2021

Changes in this version

+ type BytesMessageImpl struct

+ func (msg *BytesMessageImpl) GetBodyLength() int

+ func (msg *BytesMessageImpl) ReadBytes() *[]byte

+ func (msg *BytesMessageImpl) WriteBytes(bytes []byte)

type ConnectionFactoryImpl

+ ApplName string

+ ReceiveBufferSize int

+ func (cf ConnectionFactoryImpl) CreateContextWithSessionMode(sessionMode int) (jms20subset.JMSContext, jms20subset.JMSException)

type ConsumerImpl

+ func (consumer ConsumerImpl) ReceiveBytesBody(waitMillis int32) (*[]byte, jms20subset.JMSException)

+ func (consumer ConsumerImpl) ReceiveBytesBodyNoWait() (*[]byte, jms20subset.JMSException)

type ContextImpl

+ func (ctx ContextImpl) Commit()

+ func (ctx ContextImpl) CreateBytesMessage() jms20subset.BytesMessage

+ func (ctx ContextImpl) CreateBytesMessageWithBytes(bytes []byte) jms20subset.BytesMessage

+ func (ctx ContextImpl) Rollback()

+ type MessageImpl struct

+ func (msg *MessageImpl) GetJMSCorrelationID() string

+ func (msg *MessageImpl) GetJMSDeliveryMode() int

+ func (msg *MessageImpl) GetJMSMessageID() string

+ func (msg *MessageImpl) GetJMSReplyTo() jms20subset.Destination

+ func (msg *MessageImpl) GetJMSTimestamp() int64

+ func (msg *MessageImpl) SetJMSCorrelationID(correlID string) jms20subset.JMSException

+ func (msg *MessageImpl) SetJMSReplyTo(dest jms20subset.Destination) jms20subset.JMSException

+ func (msg MessageImpl) GetApplName() string

type ProducerImpl

+ func (producer ProducerImpl) SendBytes(dest jms20subset.Destination, body []byte) jms20subset.JMSException

Sep 29, 2019

Changes in this version

+ const TLSClientAuth_NONE

+ const TLSClientAuth_REQUIRED

+ const TransportType_BINDINGS

+ const TransportType_CLIENT

+ type ConnectionFactoryImpl struct

+ CertificateLabel string

+ ChannelName string

+ Hostname string

+ KeyRepository string

+ Password string

+ PortNumber int

+ QMName string

+ TLSCipherSpec string

+ TLSClientAuth string

+ TransportType int

+ UserName string

+ func CreateConnectionFactoryFromDefaultJSONFiles() (cf ConnectionFactoryImpl, err error)

+ func CreateConnectionFactoryFromJSON(connectionInfoLocn string, apiKeyLocn string) (cf ConnectionFactoryImpl, err error)

+ func (cf ConnectionFactoryImpl) CreateContext() (jms20subset.JMSContext, jms20subset.JMSException)

+ type ConsumerImpl struct

+ func (consumer ConsumerImpl) Close()

+ func (consumer ConsumerImpl) Receive(waitMillis int32) (jms20subset.Message, jms20subset.JMSException)

+ func (consumer ConsumerImpl) ReceiveNoWait() (jms20subset.Message, jms20subset.JMSException)

+ func (consumer ConsumerImpl) ReceiveStringBody(waitMillis int32) (*string, jms20subset.JMSException)

+ func (consumer ConsumerImpl) ReceiveStringBodyNoWait() (*string, jms20subset.JMSException)

+ type ContextImpl struct

+ func (ctx ContextImpl) Close()

+ func (ctx ContextImpl) CreateConsumer(dest jms20subset.Destination) (jms20subset.JMSConsumer, jms20subset.JMSException)

+ func (ctx ContextImpl) CreateConsumerWithSelector(dest jms20subset.Destination, selector string) (jms20subset.JMSConsumer, jms20subset.JMSException)

+ func (ctx ContextImpl) CreateProducer() jms20subset.JMSProducer

+ func (ctx ContextImpl) CreateQueue(queueName string) jms20subset.Queue

+ func (ctx ContextImpl) CreateTextMessage() jms20subset.TextMessage

+ func (ctx ContextImpl) CreateTextMessageWithString(txt string) jms20subset.TextMessage

+ type ProducerImpl struct

+ func (producer *ProducerImpl) GetDeliveryMode() int

+ func (producer *ProducerImpl) GetTimeToLive() int

+ func (producer *ProducerImpl) SetDeliveryMode(mode int) jms20subset.JMSProducer

+ func (producer *ProducerImpl) SetTimeToLive(timeToLive int) jms20subset.JMSProducer

+ func (producer ProducerImpl) Send(dest jms20subset.Destination, msg jms20subset.Message) jms20subset.JMSException

+ func (producer ProducerImpl) SendString(dest jms20subset.Destination, bodyStr string) jms20subset.JMSException

+ type QueueImpl struct

+ func (queue QueueImpl) GetDestinationName() string

+ func (queue QueueImpl) GetQueueName() string

+ type TextMessageImpl struct

+ func (msg *TextMessageImpl) GetJMSCorrelationID() string

+ func (msg *TextMessageImpl) GetJMSDeliveryMode() int

+ func (msg *TextMessageImpl) GetJMSMessageID() string

+ func (msg *TextMessageImpl) GetJMSReplyTo() jms20subset.Destination

+ func (msg *TextMessageImpl) GetJMSTimestamp() int64

+ func (msg *TextMessageImpl) GetText() *string

+ func (msg *TextMessageImpl) SetJMSCorrelationID(correlID string) jms20subset.JMSException

+ func (msg *TextMessageImpl) SetJMSReplyTo(dest jms20subset.Destination) jms20subset.JMSException

+ func (msg *TextMessageImpl) SetText(newBody string)