solace

package

Go to main page

Versions in this module

v1

v1.8.1

Dec 20, 2024

v1.8.0

Dec 13, 2024

Changes in this version

type PersistentMessageReceiver

+ Settle func(message message.InboundMessage, outcome config.MessageSettlementOutcome) error

type PersistentMessageReceiverBuilder

+ WithRequiredMessageOutcomeSupport func(messageSettlementOutcomes ...config.MessageSettlementOutcome) PersistentMessageReceiverBuilder

v1.7.0

Oct 24, 2024

Changes in this version

+ type EndpointProvisioner interface

+ Deprovision func(queueName string, ignoreMissing bool) error

+ DeprovisionAsync func(queueName string, ignoreMissing bool) <-chan error

+ DeprovisionAsyncWithCallback func(queueName string, ignoreMissing bool, callback func(err error))

+ FromConfigurationProvider func(properties config.EndpointPropertiesConfigurationProvider) EndpointProvisioner

+ GetConfiguration func() config.EndpointPropertyMap

+ Provision func(queueName string, ignoreExists bool) ProvisionOutcome

+ ProvisionAsync func(queueName string, ignoreExists bool) <-chan ProvisionOutcome

+ ProvisionAsyncWithCallback func(queueName string, ignoreExists bool, callback func(ProvisionOutcome))

+ WithDiscardNotification func(notifySender bool) EndpointProvisioner

+ WithDurability func(durable bool) EndpointProvisioner

+ WithExclusiveAccess func(exclusive bool) EndpointProvisioner

+ WithMaxMessageRedelivery func(count uint) EndpointProvisioner

+ WithMaxMessageSize func(count uint) EndpointProvisioner

+ WithPermission func(permission config.EndpointPermission) EndpointProvisioner

+ WithProperty func(propertyName config.EndpointProperty, propertyValue interface{}) EndpointProvisioner

+ WithQuotaMB func(quota uint) EndpointProvisioner

+ WithTTLPolicy func(respect bool) EndpointProvisioner

type MessagingService

+ EndpointProvisioner func() EndpointProvisioner

type MessagingServiceBuilder

+ WithProvisionTimeoutMs func(timeout time.Duration) MessagingServiceBuilder

+ type ProvisionOutcome interface

+ GetError func() error

+ GetStatus func() bool

v1.6.1

May 6, 2024

v1.6.0

Apr 29, 2024

Changes in this version

type MessagingService

+ RequestReply func() RequestReplyMessagingService

+ type Replier interface

+ Reply func(message message.OutboundMessage) error

+ type ReplyMessageHandler func(message message.InboundMessage, userContext interface{}, err error)

+ type RequestMessageHandler func(message message.InboundMessage, replier Replier)

+ type RequestReplyMessagePublisher interface

+ Publish func(requestMessage message.OutboundMessage, ...) error

+ PublishAwaitResponse func(requestMessage message.OutboundMessage, requestDestination *resource.Topic, ...) (message.InboundMessage, error)

+ PublishBytes func(message []byte, replyMessageHandler ReplyMessageHandler, ...) error

+ PublishString func(message string, replyMessageHandler ReplyMessageHandler, ...) error

+ StartAsyncCallback func(callback func(RequestReplyMessagePublisher, error))

+ TerminateAsyncCallback func(gracePeriod time.Duration, callback func(error))

+ type RequestReplyMessagePublisherBuilder interface

+ Build func() (messagePublisher RequestReplyMessagePublisher, err error)

+ FromConfigurationProvider func(provider config.PublisherPropertiesConfigurationProvider) RequestReplyMessagePublisherBuilder

+ OnBackPressureReject func(bufferSize uint) RequestReplyMessagePublisherBuilder

+ OnBackPressureWait func(bufferSize uint) RequestReplyMessagePublisherBuilder

+ type RequestReplyMessageReceiver interface

+ ReceiveAsync func(messageHandler RequestMessageHandler) error

+ ReceiveMessage func(timeout time.Duration) (message.InboundMessage, Replier, error)

+ StartAsyncCallback func(callback func(RequestReplyMessageReceiver, error))

+ TerminateAsyncCallback func(gracePeriod time.Duration, callback func(error))

+ type RequestReplyMessageReceiverBuilder interface

+ Build func(requestTopicSubscription resource.Subscription) (messageReceiver RequestReplyMessageReceiver, err error)

+ BuildWithSharedSubscription func(requestTopicSubscription resource.Subscription, shareName *resource.ShareName) (messageReceiver RequestReplyMessageReceiver, err error)

+ FromConfigurationProvider func(provider config.ReceiverPropertiesConfigurationProvider) RequestReplyMessageReceiverBuilder

+ OnBackPressureDropLatest func(bufferCapacity uint) RequestReplyMessageReceiverBuilder

+ OnBackPressureDropOldest func(bufferCapacity uint) RequestReplyMessageReceiverBuilder

+ type RequestReplyMessagingService interface

+ CreateRequestReplyMessagePublisherBuilder func() RequestReplyMessagePublisherBuilder

+ CreateRequestReplyMessageReceiverBuilder func() RequestReplyMessageReceiverBuilder

v1.5.0

Jan 22, 2024

v1.4.0

Jun 30, 2023

v1.3.0

Apr 14, 2023

v1.2.0

Jan 16, 2023

Changes in this version

type MessagingService

+ UpdateProperty func(property config.ServiceProperty, value interface{}) error

v1.1.0

Oct 31, 2022

v1.0.1

Apr 14, 2022

v1.0.0

Mar 31, 2022

Changes in this version

+ type AuthenticationError struct

+ func (err *AuthenticationError) Error() string

+ func (err *AuthenticationError) Unwrap() error

+ type DirectMessagePublisher interface

+ Publish func(message message.OutboundMessage, destination *resource.Topic) error

+ PublishBytes func(message []byte, destination *resource.Topic) error

+ PublishString func(message string, destination *resource.Topic) error

+ PublishWithProperties func(message message.OutboundMessage, destination *resource.Topic, ...) error

+ SetPublishFailureListener func(listener PublishFailureListener)

+ StartAsyncCallback func(callback func(DirectMessagePublisher, error))

+ TerminateAsyncCallback func(gracePeriod time.Duration, callback func(error))

+ type DirectMessagePublisherBuilder interface

+ Build func() (messagePublisher DirectMessagePublisher, err error)

+ FromConfigurationProvider func(provider config.PublisherPropertiesConfigurationProvider) DirectMessagePublisherBuilder

+ OnBackPressureReject func(bufferSize uint) DirectMessagePublisherBuilder

+ OnBackPressureWait func(bufferSize uint) DirectMessagePublisherBuilder

+ type DirectMessageReceiver interface

+ ReceiveAsync func(callback MessageHandler) error

+ ReceiveMessage func(timeout time.Duration) (received message.InboundMessage, err error)

+ StartAsyncCallback func(callback func(DirectMessageReceiver, error))

+ TerminateAsyncCallback func(gracePeriod time.Duration, callback func(error))

+ type DirectMessageReceiverBuilder interface

+ Build func() (messageReceiver DirectMessageReceiver, err error)

+ BuildWithShareName func(shareName *resource.ShareName) (messageReceiver DirectMessageReceiver, err error)

+ FromConfigurationProvider func(provider config.ReceiverPropertiesConfigurationProvider) DirectMessageReceiverBuilder

+ OnBackPressureDropLatest func(bufferCapacity uint) DirectMessageReceiverBuilder

+ OnBackPressureDropOldest func(bufferCapacity uint) DirectMessageReceiverBuilder

+ WithSubscriptions func(topics ...resource.Subscription) DirectMessageReceiverBuilder

+ type Error interface

+ func NewError(err Error, message string, wrapped error) Error

+ type FailedPublishEvent interface

+ GetDestination func() resource.Destination

+ GetError func() error

+ GetMessage func() message.OutboundMessage

+ GetTimeStamp func() time.Time

+ type IllegalArgumentError struct

+ func (err *IllegalArgumentError) Error() string

+ func (err *IllegalArgumentError) Unwrap() error

+ type IllegalStateError struct

+ func (err *IllegalStateError) Error() string

+ func (err *IllegalStateError) Unwrap() error

+ type IncompleteMessageDeliveryError struct

+ func (err *IncompleteMessageDeliveryError) Error() string

+ func (err *IncompleteMessageDeliveryError) Unwrap() error

+ type InvalidConfigurationError struct

+ func (err *InvalidConfigurationError) Error() string

+ func (err *InvalidConfigurationError) Unwrap() error

+ type LifecycleControl interface

+ IsRunning func() bool

+ IsTerminated func() bool

+ IsTerminating func() bool

+ SetTerminationNotificationListener func(listener TerminationNotificationListener)

+ Start func() error

+ StartAsync func() <-chan error

+ Terminate func(gracePeriod time.Duration) error

+ TerminateAsync func(gracePeriod time.Duration) <-chan error

+ type MessageHandler func(inboundMessage message.InboundMessage)

+ type MessagePublishReceiptListener func(PublishReceipt)

+ type MessagePublisher interface

+ type MessagePublisherHealthCheck interface

+ IsReady func() bool

+ NotifyWhenReady func()

+ SetPublisherReadinessListener func(listener PublisherReadinessListener)

+ type MessageReceiver interface

+ AddSubscription func(subscription resource.Subscription) error

+ AddSubscriptionAsync func(subscription resource.Subscription, listener SubscriptionChangeListener) error

+ RemoveSubscription func(subscription resource.Subscription) error

+ RemoveSubscriptionAsync func(subscription resource.Subscription, listener SubscriptionChangeListener) error

+ type MessageReplayError struct

+ func (err *MessageReplayError) Error() string

+ func (err *MessageReplayError) Unwrap() error

+ type MessagingService interface

+ AddReconnectionAttemptListener func(listener ReconnectionAttemptListener) uint64

+ AddReconnectionListener func(listener ReconnectionListener) uint64

+ AddServiceInterruptionListener func(listener ServiceInterruptionListener) uint64

+ Connect func() error

+ ConnectAsync func() <-chan error

+ ConnectAsyncWithCallback func(callback func(MessagingService, error))

+ CreateDirectMessagePublisherBuilder func() DirectMessagePublisherBuilder

+ CreateDirectMessageReceiverBuilder func() DirectMessageReceiverBuilder

+ CreatePersistentMessagePublisherBuilder func() PersistentMessagePublisherBuilder

+ CreatePersistentMessageReceiverBuilder func() PersistentMessageReceiverBuilder

+ Disconnect func() error

+ DisconnectAsync func() <-chan error

+ DisconnectAsyncWithCallback func(callback func(error))

+ GetApplicationID func() string

+ Info func() metrics.APIInfo

+ IsConnected func() bool

+ MessageBuilder func() OutboundMessageBuilder

+ Metrics func() metrics.APIMetrics

+ RemoveReconnectionAttemptListener func(listenerID uint64)

+ RemoveReconnectionListener func(listenerID uint64)

+ RemoveServiceInterruptionListener func(listenerID uint64)

+ type MessagingServiceBuilder interface

+ Build func() (messagingService MessagingService, err error)

+ BuildWithApplicationID func(applicationID string) (messagingService MessagingService, err error)

+ FromConfigurationProvider func(provider config.ServicePropertiesConfigurationProvider) MessagingServiceBuilder

+ WithAuthenticationStrategy func(authenticationStrategy config.AuthenticationStrategy) MessagingServiceBuilder

+ WithConnectionRetryStrategy func(retryStrategy config.RetryStrategy) MessagingServiceBuilder

+ WithMessageCompression func(compressionFactor int) MessagingServiceBuilder

+ WithReconnectionRetryStrategy func(retryStrategy config.RetryStrategy) MessagingServiceBuilder

+ WithTransportSecurityStrategy func(transportSecurityStrategy config.TransportSecurityStrategy) MessagingServiceBuilder

+ type NativeError struct

+ func NewNativeError(message string, subcode subcode.Code) *NativeError

+ func (err *NativeError) Error() string

+ func (err *NativeError) SubCode() subcode.Code

+ type OutboundMessageBuilder interface

+ Build func(additionalConfiguration ...config.MessagePropertiesConfigurationProvider) (message.OutboundMessage, error)

+ BuildWithByteArrayPayload func(payload []byte, ...) (message message.OutboundMessage, err error)

+ BuildWithMapPayload func(payload sdt.Map, ...) (message message.OutboundMessage, err error)

+ BuildWithStreamPayload func(payload sdt.Stream, ...) (message message.OutboundMessage, err error)

+ BuildWithStringPayload func(payload string, ...) (message message.OutboundMessage, err error)

+ FromConfigurationProvider func(properties config.MessagePropertiesConfigurationProvider) OutboundMessageBuilder

+ WithApplicationMessageID func(messageID string) OutboundMessageBuilder

+ WithApplicationMessageType func(messageType string) OutboundMessageBuilder

+ WithCorrelationID func(correlationID string) OutboundMessageBuilder

+ WithExpiration func(t time.Time) OutboundMessageBuilder

+ WithHTTPContentHeader func(contentType, contentEncoding string) OutboundMessageBuilder

+ WithPriority func(priority int) OutboundMessageBuilder

+ WithProperty func(propertyName config.MessageProperty, propertyValue interface{}) OutboundMessageBuilder

+ WithSenderID func(senderID string) OutboundMessageBuilder

+ WithSequenceNumber func(sequenceNumber uint64) OutboundMessageBuilder

+ type PersistentMessagePublisher interface

+ Publish func(message message.OutboundMessage, destination *resource.Topic, ...) error

+ PublishAwaitAcknowledgement func(message message.OutboundMessage, destination *resource.Topic, ...) error

+ PublishBytes func(message []byte, destination *resource.Topic) error

+ PublishString func(message string, destination *resource.Topic) error

+ SetMessagePublishReceiptListener func(listener MessagePublishReceiptListener)

+ StartAsyncCallback func(callback func(PersistentMessagePublisher, error))

+ TerminateAsyncCallback func(gracePeriod time.Duration, callback func(error))

+ type PersistentMessagePublisherBuilder interface

+ Build func() (messagePublisher PersistentMessagePublisher, err error)

+ FromConfigurationProvider func(provider config.PublisherPropertiesConfigurationProvider) PersistentMessagePublisherBuilder

+ OnBackPressureReject func(bufferSize uint) PersistentMessagePublisherBuilder

+ OnBackPressureWait func(bufferSize uint) PersistentMessagePublisherBuilder

+ type PersistentMessageReceiver interface

+ Ack func(message message.InboundMessage) error

+ Pause func() error

+ ReceiveAsync func(callback MessageHandler) error

+ ReceiveMessage func(timeout time.Duration) (message.InboundMessage, error)

+ ReceiverInfo func() (info PersistentReceiverInfo, err error)

+ Resume func() error

+ StartAsyncCallback func(callback func(PersistentMessageReceiver, error))

+ TerminateAsyncCallback func(gracePeriod time.Duration, callback func(error))

+ type PersistentMessageReceiverBuilder interface

+ Build func(queue *resource.Queue) (receiver PersistentMessageReceiver, err error)

+ FromConfigurationProvider func(provider config.ReceiverPropertiesConfigurationProvider) PersistentMessageReceiverBuilder

+ WithActivationPassivationSupport func(listener ReceiverStateChangeListener) PersistentMessageReceiverBuilder

+ WithMessageAutoAcknowledgement func() PersistentMessageReceiverBuilder

+ WithMessageClientAcknowledgement func() PersistentMessageReceiverBuilder

+ WithMessageReplay func(strategy config.ReplayStrategy) PersistentMessageReceiverBuilder

+ WithMessageSelector func(filterSelectorExpression string) PersistentMessageReceiverBuilder

+ WithMissingResourcesCreationStrategy func(strategy config.MissingResourcesCreationStrategy) PersistentMessageReceiverBuilder

+ WithSubscriptions func(topics ...resource.Subscription) PersistentMessageReceiverBuilder

+ type PersistentReceiverInfo interface

+ GetResourceInfo func() ResourceInfo

+ type PublishFailureListener func(FailedPublishEvent)

+ type PublishReceipt interface

+ GetError func() error

+ GetMessage func() message.OutboundMessage

+ GetTimeStamp func() time.Time

+ GetUserContext func() interface{}

+ IsPersisted func() bool

+ type PublisherOverflowError struct

+ func (err *PublisherOverflowError) Error() string

+ func (err *PublisherOverflowError) Unwrap() error

+ type PublisherReadinessListener func()

+ type ReceiverState byte

+ const ReceiverActive

+ const ReceiverPassive

+ type ReceiverStateChangeListener func(oldState ReceiverState, newState ReceiverState, timestamp time.Time)

+ type ReconnectionAttemptListener func(event ServiceEvent)

+ type ReconnectionListener func(event ServiceEvent)

+ type ResourceInfo interface

+ GetName func() string

+ IsDurable func() bool

+ type ServiceEvent interface

+ GetBrokerURI func() string

+ GetCause func() error

+ GetMessage func() string

+ GetTimestamp func() time.Time

+ type ServiceInterruptionListener func(event ServiceEvent)

+ type ServiceUnreachableError struct

+ func (err *ServiceUnreachableError) Error() string

+ func (err *ServiceUnreachableError) Unwrap() error

+ type SubscriptionChangeListener func(subscription resource.Subscription, operation SubscriptionOperation, ...)

+ type SubscriptionOperation byte

+ const SubscriptionAdded

+ const SubscriptionRemoved

+ type TerminationEvent interface

+ GetCause func() error

+ GetMessage func() string

+ GetTimestamp func() time.Time

+ type TerminationNotificationListener func(TerminationEvent)

+ type TimeoutError struct

+ func (err *TimeoutError) Error() string

+ func (err *TimeoutError) Unwrap() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL