File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff 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 ]
Original file line number Diff line number Diff 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,
Original file line number Diff line number Diff line change @@ -11,7 +11,7 @@ import type { OutboxEntry } from './objects'
1111 * - returned entries should not include the ones with 'SUCCESS' status
1212 */
1313export interface OutboxStorage < SupportedEvents extends CommonEventDefinition [ ] > {
14- create (
14+ createEntry (
1515 outboxEntry : OutboxEntry < SupportedEvents [ number ] > ,
1616 ) : Promise < OutboxEntry < SupportedEvents [ number ] > >
1717
You can’t perform that action at this time.
0 commit comments