From 9f4374c7efe29e121b9d97127f0216f06fd0b946 Mon Sep 17 00:00:00 2001 From: Scott Nichols Date: Fri, 29 Mar 2019 13:53:32 -0700 Subject: [PATCH] Migrate to correct sdk usage. --- pkg/broker/receiver.go | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/pkg/broker/receiver.go b/pkg/broker/receiver.go index 507c3af55ff..a03e730ed7b 100644 --- a/pkg/broker/receiver.go +++ b/pkg/broker/receiver.go @@ -34,8 +34,6 @@ import ( ) const ( - defaultPort = 8080 - writeTimeout = 1 * time.Minute ) @@ -44,17 +42,12 @@ type Receiver struct { logger *zap.Logger client client.Client ceClient ceclient.Client - ceHTTP *cehttp.Transport } // New creates a new Receiver and its associated MessageReceiver. The caller is responsible for // Start()ing the returned MessageReceiver. func New(logger *zap.Logger, client client.Client) (*Receiver, error) { - ceHTTP, err := cehttp.New(cehttp.WithBinaryEncoding(), cehttp.WithPort(defaultPort)) - if err != nil { - return nil, err - } - ceClient, err := ceclient.New(ceHTTP) + ceClient, err := ceclient.NewDefault() if err != nil { return nil, err } @@ -63,7 +56,6 @@ func New(logger *zap.Logger, client client.Client) (*Receiver, error) { logger: logger, client: client, ceClient: ceClient, - ceHTTP: ceHTTP, } err = r.initClient() if err != nil { @@ -204,7 +196,7 @@ func (r *Receiver) sendEvent(ctx context.Context, tctx cehttp.TransportContext, } sendingCTX := SendingContext(ctx, tctx, subscriberURI) - return r.ceHTTP.Send(sendingCTX, *event) + return r.ceClient.Send(sendingCTX, *event) } func (r *Receiver) getTrigger(ctx context.Context, ref provisioners.ChannelReference) (*eventingv1alpha1.Trigger, error) {