Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CPHMessageHandler ¶
type CPHMessageHandler struct { MessageConsumer consumer.MessageConsumer // contains filtered or unexported fields }
func NewCPHMessageHandler ¶
func NewCPHMessageHandler(c consumer.MessageConsumer, p producer.MessageProducer, mapper mapper.CPHAggregateMapper, nativeMapper mapper.MessageToContentPlaceholderMapper, messageCreator message.MessageCreator) *CPHMessageHandler
func (*CPHMessageHandler) HandleMessage ¶
func (kqh *CPHMessageHandler) HandleMessage(msg consumer.Message)
func (*CPHMessageHandler) StartHandlingMessages ¶
func (kqh *CPHMessageHandler) StartHandlingMessages()
type MessageHandler ¶
Click to show internal directories.
Click to hide internal directories.