7
7
import com .launchdarkly .client .integrations .PollingDataSourceBuilder ;
8
8
import com .launchdarkly .client .integrations .StreamingDataSourceBuilder ;
9
9
import com .launchdarkly .client .interfaces .DiagnosticDescription ;
10
+ import com .launchdarkly .client .interfaces .EventSender ;
10
11
import com .launchdarkly .client .interfaces .HttpAuthentication ;
11
12
import com .launchdarkly .client .interfaces .HttpConfiguration ;
12
13
import com .launchdarkly .client .interfaces .PersistentDataStoreFactory ;
@@ -393,12 +394,18 @@ public EventProcessor createEventProcessor(String sdkKey, LDConfig config,
393
394
if (config .offline || !config .deprecatedSendEvents ) {
394
395
return new NullEventProcessor ();
395
396
}
396
- return new DefaultEventProcessor (sdkKey ,
397
+ URI eventsBaseUri = config .deprecatedEventsURI == null ? LDConfig .DEFAULT_EVENTS_URI : config .deprecatedEventsURI ;
398
+ EventSender eventSender = new DefaultEventSender .Factory ().createEventSender (
399
+ sdkKey ,
400
+ config .httpConfig
401
+ );
402
+ return new DefaultEventProcessor (
397
403
config ,
398
404
new EventsConfiguration (
399
405
config .deprecatedAllAttributesPrivate ,
400
406
config .deprecatedCapacity ,
401
- config .deprecatedEventsURI == null ? LDConfig .DEFAULT_EVENTS_URI : config .deprecatedEventsURI ,
407
+ eventSender ,
408
+ eventsBaseUri ,
402
409
config .deprecatedFlushInterval ,
403
410
config .deprecatedInlineUsersInEvents ,
404
411
config .deprecatedPrivateAttrNames ,
@@ -407,7 +414,6 @@ public EventProcessor createEventProcessor(String sdkKey, LDConfig config,
407
414
config .deprecatedUserKeysFlushInterval ,
408
415
EventProcessorBuilder .DEFAULT_DIAGNOSTIC_RECORDING_INTERVAL_SECONDS
409
416
),
410
- config .httpConfig ,
411
417
diagnosticAccumulator
412
418
);
413
419
}
@@ -667,11 +673,15 @@ public EventProcessor createEventProcessor(String sdkKey, LDConfig config, Diagn
667
673
if (config .offline ) {
668
674
return new NullEventProcessor ();
669
675
}
670
- return new DefaultEventProcessor (sdkKey ,
676
+ EventSender eventSender =
677
+ (eventSenderFactory == null ? new DefaultEventSender .Factory () : eventSenderFactory )
678
+ .createEventSender (sdkKey , config .httpConfig );
679
+ return new DefaultEventProcessor (
671
680
config ,
672
681
new EventsConfiguration (
673
682
allAttributesPrivate ,
674
683
capacity ,
684
+ eventSender ,
675
685
baseURI == null ? LDConfig .DEFAULT_EVENTS_URI : baseURI ,
676
686
flushIntervalSeconds ,
677
687
inlineUsersInEvents ,
@@ -681,7 +691,6 @@ public EventProcessor createEventProcessor(String sdkKey, LDConfig config, Diagn
681
691
userKeysFlushIntervalSeconds ,
682
692
diagnosticRecordingIntervalSeconds
683
693
),
684
- config .httpConfig ,
685
694
diagnosticAccumulator
686
695
);
687
696
}
0 commit comments