Skip to content

Commit

Permalink
Removed the wrong time defaulting
Browse files Browse the repository at this point in the history
Signed-off-by: Francesco Guardiani <[email protected]>
  • Loading branch information
slinkydeveloper committed Jun 24, 2020
1 parent ce9a058 commit cad09f0
Showing 1 changed file with 3 additions and 9 deletions.
12 changes: 3 additions & 9 deletions pkg/channel/message_receiver.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,19 +24,15 @@ import (
"time"

"github.com/cloudevents/sdk-go/v2/binding"
"github.com/cloudevents/sdk-go/v2/binding/transformer"
"github.com/cloudevents/sdk-go/v2/protocol/http"
"go.uber.org/zap"

"knative.dev/pkg/network"

"knative.dev/eventing/pkg/kncloudevents"
"knative.dev/eventing/pkg/utils"
"knative.dev/pkg/network"
)

var defaultTransformers = []binding.Transformer{
transformer.AddTimeNow,
}

// UnknownChannelError represents the error when an event is received by a channel dispatcher for a
// channel that does not exist.
type UnknownChannelError struct {
Expand Down Expand Up @@ -176,9 +172,7 @@ func (r *MessageReceiver) ServeHTTP(response nethttp.ResponseWriter, request *ne
return
}

transformers := append(defaultTransformers, AddHistory(host))

err = r.receiverFunc(request.Context(), channel, message, transformers, utils.PassThroughHeaders(request.Header))
err = r.receiverFunc(request.Context(), channel, message, []binding.Transformer{AddHistory(host)}, utils.PassThroughHeaders(request.Header))
if err != nil {
if _, ok := err.(*UnknownChannelError); ok {
response.WriteHeader(nethttp.StatusNotFound)
Expand Down

0 comments on commit cad09f0

Please sign in to comment.