Documentation
¶
Index ¶
- type MyEventConsumerInterceptorAdaptor
- func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) HandleError(consumedTopic messaging.Topic, receivedMessage messaging.Message, err error) bool
- func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePostProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
- func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreParsing(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
- func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
- func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) ProcessingCompletedNormally(consumedTopic messaging.Topic, receivedMessage messaging.Message)
- type MyEventProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MyEventConsumerInterceptorAdaptor ¶
type MyEventConsumerInterceptorAdaptor struct {
IncomingMessagePreParsingCalled bool
IncomingMessagePreProcessMessageCalled bool
IncomingMessagePostProcessMessageCalled bool
HandleErrorCalled bool
ProcessingCompletedNormallyCalled bool
}
MyEventConsumerInterceptorAdaptor is an implementation og EventConsumerAdaptor similar to EventConsumerInterceptorAdaptor, but testing purposes
func NewMyEventConsumerInterceptorAdaptor ¶
func NewMyEventConsumerInterceptorAdaptor() MyEventConsumerInterceptorAdaptor
NewMyEventConsumerInterceptorAdaptor functions as a constructor for MyEventConsumerInterceptorAdaptor, returning a new instance of MyEventConsumerInterceptorAdaptor with all 'called'-variables set to false
func (*MyEventConsumerInterceptorAdaptor) HandleError ¶
func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) HandleError(consumedTopic messaging.Topic, receivedMessage messaging.Message, err error) bool
HandleError is a test implementation of EventConsumerInterceptor's HandleError
func (*MyEventConsumerInterceptorAdaptor) IncomingMessagePostProcessMessage ¶
func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePostProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
IncomingMessagePostProcessMessage is a test implementation of EventConsumerInterceptor's IncomingMessagePostProcessMessage
func (*MyEventConsumerInterceptorAdaptor) IncomingMessagePreParsing ¶
func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreParsing(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
IncomingMessagePreParsing is a test implementation of EventConsumerInterceptor's IncomingMessagePreParsing
func (*MyEventConsumerInterceptorAdaptor) IncomingMessagePreProcessMessage ¶
func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) IncomingMessagePreProcessMessage(consumedTopic messaging.Topic, receivedMessage messaging.Message) bool
IncomingMessagePreProcessMessage is a test implementation of EventConsumerInterceptor's IncomingMessagePreProcessMessage
func (*MyEventConsumerInterceptorAdaptor) ProcessingCompletedNormally ¶
func (eventConsumerInterceptorAdaptor *MyEventConsumerInterceptorAdaptor) ProcessingCompletedNormally(consumedTopic messaging.Topic, receivedMessage messaging.Message)
ProcessingCompletedNormally is a test implementation of EventConsumerInterceptor's ProcessingCompletedNormally
type MyEventProcessor ¶
type MyEventProcessor struct{}
MyEventProcessor is a struct representing MyEventProcessor which processes events received from Kafka, and returns a new message based on this processing
func NewMyEventProcessor ¶
func NewMyEventProcessor(ctx context.Context) (MyEventProcessor, error)
NewMyEventProcessor functions as a constructor for MyEventProcessor that returns a new instance of MyEventProcessor
func (MyEventProcessor) ProcessMessage ¶
func (mep MyEventProcessor) ProcessMessage( ctx context.Context, consumedTopic messaging.Topic, receivedMessage messaging.Message, messageProcessedTopic *messaging.Topic, outgoingMessage *messaging.Message, ) error
ProcessMessage accepts messages from Kafka and outputs an OperationOutcome resource to a different Topic
Source Files
Directories