diff --git a/pkg/event/processor.go b/pkg/event/processor.go index 6e02d21a..b291d159 100644 --- a/pkg/event/processor.go +++ b/pkg/event/processor.go @@ -161,10 +161,6 @@ func NewBatchEventProcessor(options ...BPOptionConfig) *BatchEventProcessor { p.BatchSize = DefaultBatchSize } - if p.EventEndPoint == "" { - p.EventEndPoint = EventEndPoints["US"] - } - if p.BatchSize > p.MaxQueueSize { p.logger.Warning( fmt.Sprintf("Batch size %d is larger than queue size %d. Setting to defaults", diff --git a/pkg/event/processor_test.go b/pkg/event/processor_test.go index d5033861..447dd12b 100644 --- a/pkg/event/processor_test.go +++ b/pkg/event/processor_test.go @@ -122,7 +122,7 @@ func TestCustomEventProcessor_Create(t *testing.T) { func TestEndPointOptionEventProcessor(t *testing.T) { // Default end point processor := NewBatchEventProcessor() - assert.Equal(t, EventEndPoints["US"], processor.EventEndPoint) + assert.Equal(t, "", processor.EventEndPoint) customEndPoint := "https://logx.optimizely.com" processor = NewBatchEventProcessor( @@ -133,7 +133,7 @@ func TestEndPointOptionEventProcessor(t *testing.T) { func TestEndPointOptionEU(t *testing.T) { // Default end point processor := NewBatchEventProcessor() - assert.Equal(t, EventEndPoints["US"], processor.EventEndPoint) + assert.Equal(t, "", processor.EventEndPoint) euEndpoint := EventEndPoints["EU"] processor = NewBatchEventProcessor(