Method HandleMessage

consumer.go:66–66 · view source on GitHub ↗

(context.Context, *MessageIncoming)

Source from the content-addressed store, hash-verified

64	// // \| true \| some error \| processed, ended with error. Don't retry! \|
65	type MessageHandler interface {
66	HandleMessage(context.Context, *MessageIncoming) (processed bool, err error)
67	}
68
69	// MessageHandlerFunc is MessageHandler implementation by simple function.

handleMessageMethod · 0.65

Handlerexample_consumer_test.go

regularHandlerintegtest/consumer_test.go

slowHandlerintegtest/consumer_test.go

no outgoing calls

no test coverage detected