Versions in this module Expand all Collapse all v0 v0.2.7 Jul 17, 2021 v0.2.6 Jul 17, 2021 v0.2.5 Apr 9, 2021 Changes in this version + const Java + const JavaIBMZ + const JavaPPC + const MountPath + const NodeJS + const Python + const Timeout + var QEClientImageMap = map[AmqpQEClientImpl]AmqpQEClientImplInfo + type AmqpQEClientBuilderCommon struct + MessageCount int + func (a *AmqpQEClientBuilderCommon) CustomImage(image string) *AmqpQEClientBuilderCommon + func (a *AmqpQEClientBuilderCommon) Messages(count int) *AmqpQEClientBuilderCommon + func (a *AmqpQEClientBuilderCommon) WithCustomCommand(command string) *AmqpQEClientBuilderCommon + type AmqpQEClientCommon struct + Implementation AmqpQEClientImpl + func (a *AmqpQEClientCommon) Result() amqp.ResultData + type AmqpQEClientImpl int + type AmqpQEClientImplInfo struct + CommandReceiver string + CommandSender string + Image string + Name string + type AmqpQEReceiverBuilder struct + func NewReceiverBuilder(name string, impl AmqpQEClientImpl, data framework.ContextData, url string) *AmqpQEReceiverBuilder + func (a *AmqpQEReceiverBuilder) Build() (*AmqpQEClientCommon, error) + func (a *AmqpQEReceiverBuilder) Timeout(timeout int) *AmqpQEReceiverBuilder + func (a *AmqpQEReceiverBuilder) WithCount(count int) *AmqpQEReceiverBuilder + type AmqpQESenderBuilder struct + ContentConfigMap string + MessageContent string + MessageContentFromFileKey string + func NewSenderBuilder(name string, impl AmqpQEClientImpl, data framework.ContextData, url string) *AmqpQESenderBuilder + func (a *AmqpQESenderBuilder) Build() (*AmqpQEClientCommon, error) + func (a *AmqpQESenderBuilder) Content(content string) *AmqpQESenderBuilder + func (a *AmqpQESenderBuilder) Count(count int) *AmqpQESenderBuilder + func (a *AmqpQESenderBuilder) MessageContentFromFile(configMapName string, filenameKey string) *AmqpQESenderBuilder + func (a *AmqpQESenderBuilder) Timeout(timeout int) *AmqpQESenderBuilder + type MessageDict struct + AbsExpTime int + Address string + Annotations string + Content string + ContentEncoding string + ContentType string + CorrelationId string + CreationTime float32 + DeliveryCount int + Durable bool + Expiration int + FirstAcquirer bool + GroupId string + GroupSequence int + Id string + Inferred bool + Instructions string + Priority int + Properties map[string]interface{} + ReplyTo string + ReplyToGroupId string + RouterLink int + Subject string + Ttl int + UserId string + func (m MessageDict) ToMessage() amqp.Message
Go to main page