HandleMessage calls self. It also implements MessageHandler interface.
(ctx context.Context, msg *MessageIncoming)
| 71 | |
| 72 | // HandleMessage calls self. It also implements MessageHandler interface. |
| 73 | func (fn MessageHandlerFunc) HandleMessage(ctx context.Context, msg *MessageIncoming) (processed bool, err error) { |
| 74 | return fn(ctx, msg) |
| 75 | } |
| 76 | |
| 77 | // consumerConfig contains consumer configuration. |
| 78 | type consumerConfig struct { |
nothing calls this directly
no outgoing calls
no test coverage detected