Fixed wrong file naming

Signed-off-by: Francesco Guardiani <[email protected]>
knative · Mar 18, 2020 · 219881e · 219881e
1 parent 0967f57
commit 219881e
Show file tree

Hide file tree

Showing 6 changed files with 4 additions and 3 deletions.
diff --git a/pkg/channel/fanout/fanout_handler_binding.go → pkg/channel/fanout/fanout_message_handler.go b/pkg/channel/fanout/fanout_handler_binding.go → pkg/channel/fanout/fanout_message_handler.go
@@ -92,14 +92,15 @@ func (f *MessageHandler) ServeHTTP(response nethttp.ResponseWriter, request *net
 
 // dispatch takes the event, fans it out to each subscription in f.config. If all the fanned out
 // events return successfully, then return nil. Else, return an error.
-func (f *MessageHandler) dispatch(ctx context.Context, message binding.Message, transformers []binding.TransformerFactory, additionalHeaders nethttp.Header) error {
+func (f *MessageHandler) dispatch(ctx context.Context, originalMessage binding.Message, transformers []binding.TransformerFactory, additionalHeaders nethttp.Header) error {
 	// We buffer the message and bind the lifecycle with all fanout requests acks from other messages are received
 	subs := len(f.config.Subscriptions)
-	var err error
-	message, err = buffering.BufferMessage(ctx, message, transformers)
+	message, err := buffering.BufferMessage(ctx, originalMessage, transformers)
 	if err != nil {
 		return err
 	}
+	_ = originalMessage.Finish(nil)
+
 	message = buffering.WithAcksBeforeFinish(message, subs)
 
 	errorCh := make(chan error, subs)

diff --git a/...nel/fanout/fanout_handler_binding_test.go → ...nel/fanout/fanout_message_handler_test.go b/...nel/fanout/fanout_handler_binding_test.go → ...nel/fanout/fanout_message_handler_test.go
diff --git a/...t/multi_channel_fanout_handler_binding.go → ...t/multi_channel_fanout_message_handler.go b/...t/multi_channel_fanout_handler_binding.go → ...t/multi_channel_fanout_message_handler.go
diff --git a/...ti_channel_fanout_handler_binding_test.go → ...ti_channel_fanout_message_handler_test.go b/...ti_channel_fanout_handler_binding_test.go → ...ti_channel_fanout_message_handler_test.go
diff --git a/pkg/channel/swappable/swappable_binding.go → ...el/swappable/swappable_message_handler.go b/pkg/channel/swappable/swappable_binding.go → ...el/swappable/swappable_message_handler.go
diff --git a/...annel/swappable/swappable_binding_test.go → ...appable/swappable_message_handler_test.go b/...annel/swappable/swappable_binding_test.go → ...appable/swappable_message_handler_test.go