@cheep/transport
Advanced tools
Comparing version 1.0.3 to 1.0.4
{ | ||
"name": "@cheep/transport", | ||
"version": "1.0.3", | ||
"version": "1.0.4", | ||
"contributors": [ | ||
@@ -5,0 +5,0 @@ "Ezeki", |
@@ -1,5 +0,4 @@ | ||
import { MessageMetadata } from './transport'; | ||
import { SendMessageProps, SendReplyMessageProps, TransportBase, TransportOptions, TransportUtils } from './transport.base'; | ||
export declare class MemoryTransport<TMeta extends MessageMetadata = MessageMetadata> extends TransportBase { | ||
protected options: TransportOptions<TMeta> & { | ||
export declare class MemoryTransport extends TransportBase { | ||
protected options: TransportOptions & { | ||
messageDelayTime?: number; | ||
@@ -9,3 +8,3 @@ }; | ||
private uniqueIndex; | ||
constructor(options?: TransportOptions<TMeta> & { | ||
constructor(options?: TransportOptions & { | ||
messageDelayTime?: number; | ||
@@ -12,0 +11,0 @@ }, utils?: TransportUtils); |
import { NormalizedError } from './domain/normalizeError'; | ||
import { ExecuteProps, FireAndForgetHandler, MessageMetadata, MetadataReducer, MetadataValidator, PublishProps, RawHandler, RouteHandler, Transport, TransportMessage, TransportState } from './transport'; | ||
export interface TransportOptions<TMeta extends MessageMetadata = MessageMetadata> { | ||
export interface TransportOptions { | ||
defaultRpcTimeout?: number; | ||
metadataReducers?: MetadataReducer<TMeta>[]; | ||
metadataValidator?: MetadataValidator<TMeta>[]; | ||
metadataReducers?: MetadataReducer<MessageMetadata>[]; | ||
metadataValidator?: MetadataValidator<MessageMetadata>[]; | ||
failedMessagesQueueName?: string; | ||
@@ -8,0 +8,0 @@ } |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
73957
1155