Skip to content

Commit 1569d17

Browse files
committed
Fix maxQueueSize
1 parent fc56d82 commit 1569d17

File tree

2 files changed

+11
-2
lines changed

2 files changed

+11
-2
lines changed

packages/event-processor/src/eventProcessor.ts

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
// TODO change this to use Managed from js-sdk-models when available
1717
import { Managed } from './managed'
1818
import { ConversionEvent, ImpressionEvent } from './events'
19-
import { EventV1Request } from './eventDispatcher'
19+
import { EventV1Request, EventDispatcher } from './eventDispatcher'
2020
import { EventQueue, DefaultEventQueue, SingleEventQueue } from './eventQueue'
2121
import { getLogger } from '@optimizely/js-sdk-logging'
2222
import { NOTIFICATION_TYPES, NotificationCenter } from '@optimizely/js-sdk-utils'
@@ -34,6 +34,14 @@ export interface EventProcessor extends Managed {
3434
process(event: Partial<ProcessableEvent>): void
3535
}
3636

37+
export interface LogTierV1EventProcessorConfig {
38+
dispatcher: EventDispatcher;
39+
flushInterval?: number;
40+
batchSize?: number;
41+
notificationCenter?: NotificationCenter;
42+
maxQueueSize?: number;
43+
}
44+
3745
export function validateAndGetFlushInterval(flushInterval: number): number {
3846
if (flushInterval <= 0) {
3947
logger.warn(

packages/optimizely-sdk/lib/optimizely/index.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
***************************************************************************/
1616
import { sprintf, objectValues } from '@optimizely/js-sdk-utils';
1717
import { LogHandler, ErrorHandler } from '@optimizely/js-sdk-logging';
18+
import { LogTierV1EventProcessorConfig } from '../../../event-processor/src';
1819
import * as eventProcessor from '@optimizely/js-sdk-event-processor';
1920
import { FeatureFlag, FeatureVariable } from '../core/project_config/entities';
2021
import { EventDispatcher } from '@optimizely/js-sdk-event-processor';
@@ -139,7 +140,7 @@ export default class Optimizely {
139140
batchSize: config.eventBatchSize,
140141
maxQueueSize: config.eventMaxQueueSize, // TODO: update event-processor to include maxQueueSize
141142
notificationCenter: this.notificationCenter,
142-
});
143+
} as LogTierV1EventProcessorConfig);
143144

144145

145146
const eventProcessorStartedPromise = this.eventProcessor.start();

0 commit comments

Comments
 (0)