@cheep/transport
Advanced tools
Comparing version 1.0.0-beta.21 to 1.0.0-beta.25
{ | ||
"name": "@cheep/transport", | ||
"version": "1.0.0-beta.21", | ||
"version": "1.0.0-beta.25", | ||
"main": "src/index.js", | ||
"typings": "src/index.d.ts" | ||
} |
@@ -10,5 +10,4 @@ export * from './lib/domain/normalizeError'; | ||
export * from './lib/rpcTimeout.error'; | ||
export * from './lib/failedMessage.error'; | ||
export * from './lib/transport'; | ||
export * from './lib/transport.base'; | ||
export * from './lib/constants'; |
@@ -13,3 +13,2 @@ "use strict"; | ||
tslib_1.__exportStar(require("./lib/rpcTimeout.error"), exports); | ||
tslib_1.__exportStar(require("./lib/failedMessage.error"), exports); | ||
tslib_1.__exportStar(require("./lib/transport"), exports); | ||
@@ -16,0 +15,0 @@ tslib_1.__exportStar(require("./lib/transport.base"), exports); |
@@ -11,3 +11,2 @@ "use strict"; | ||
const constants_1 = require("./constants"); | ||
const failedMessage_error_1 = require("./failedMessage.error"); | ||
const HANDLER_META = Symbol('ROUTE_HANDLER'); | ||
@@ -193,8 +192,3 @@ class TransportBase { | ||
} | ||
const fullFailedMessage = this.utils.jsonEncode({ | ||
metadata: message.metadata, | ||
payload: message.payload, | ||
errorData: normalizeError_1.normalizeError(err), | ||
}); | ||
throw new failedMessage_error_1.FailedMessageError(err, fullFailedMessage); | ||
throw err; | ||
} | ||
@@ -201,0 +195,0 @@ } |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
52629
47
846