receiver

Documentation

Overview

Package receiver ise defined below

Index

• Constants
• func NewDirectMessageReceiverBuilderImpl(internalReceiver core.Receiver) solace.DirectMessageReceiverBuilder
• func NewPersistentMessageReceiverBuilderImpl(internalReceiver core.Receiver) solace.PersistentMessageReceiverBuilder
• func NewReplierImpl(requestMsg apimessage.InboundMessage, internalReceiver core.Receiver) (solace.Replier, bool)
• func NewRequestReplyMessageReceiverBuilderImpl(internalReceiver core.Receiver) solace.RequestReplyMessageReceiverBuilder

Constants

const MaxOutstandingCacheRequests int64 = 1024

MaxOutstandingCacheRequests indicates the maximum number of cache responses that can be buffered by the API without being processed by the application.

Functions

func NewDirectMessageReceiverBuilderImpl

func NewDirectMessageReceiverBuilderImpl(internalReceiver core.Receiver) solace.DirectMessageReceiverBuilder

NewDirectMessageReceiverBuilderImpl function

func NewPersistentMessageReceiverBuilderImpl

func NewPersistentMessageReceiverBuilderImpl(internalReceiver core.Receiver) solace.PersistentMessageReceiverBuilder

NewPersistentMessageReceiverBuilderImpl function

func NewReplierImpl

func NewReplierImpl(requestMsg apimessage.InboundMessage, internalReceiver core.Receiver) (solace.Replier, bool)

NewReplierImpl function

func NewRequestReplyMessageReceiverBuilderImpl

func NewRequestReplyMessageReceiverBuilderImpl(internalReceiver core.Receiver) solace.RequestReplyMessageReceiverBuilder

NewRequestReplyMessageReceiverBuilderImpl function