Skip to content

Commit 34dff00

Browse files
committed
AP-5046 createEntry.
1 parent db1e1e3 commit 34dff00

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

packages/outbox-core/lib/outbox.spec.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ class InMemoryOutboxStorage<SupportedEvents extends CommonEventDefinition[]>
5959
{
6060
public entries: OutboxEntry<SupportedEvents[number]>[] = []
6161

62-
create(
62+
createEntry(
6363
outboxEntry: OutboxEntry<SupportedEvents[number]>,
6464
): Promise<OutboxEntry<SupportedEvents[number]>> {
6565
this.entries = [...this.entries, outboxEntry]

packages/outbox-core/lib/outbox.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ export class OutboxEventEmitter<SupportedEvents extends CommonEventDefinition[]>
126126
data: Omit<CommonEventDefinitionPublisherSchemaType<SupportedEvent>, 'type'>,
127127
precedingMessageMetadata?: Partial<ConsumerMessageMetadataType>,
128128
) {
129-
await this.storage.create({
129+
await this.storage.createEntry({
130130
id: uuidv7(),
131131
event: supportedEvent,
132132
data,

packages/outbox-core/lib/storage.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import type { OutboxEntry } from './objects'
1111
* - returned entries should not include the ones with 'SUCCESS' status
1212
*/
1313
export interface OutboxStorage<SupportedEvents extends CommonEventDefinition[]> {
14-
create(
14+
createEntry(
1515
outboxEntry: OutboxEntry<SupportedEvents[number]>,
1616
): Promise<OutboxEntry<SupportedEvents[number]>>
1717

0 commit comments

Comments
 (0)