UNPKG

698 BJavaScriptView Raw
1"use strict";
2Object.defineProperty(exports, "__esModule", { value: true });
3exports.RmqContext = void 0;
4const base_rpc_context_1 = require("./base-rpc.context");
5class RmqContext extends base_rpc_context_1.BaseRpcContext {
6 constructor(args) {
7 super(args);
8 }
9 /**
10 * Returns the original message (with properties, fields, and content).
11 */
12 getMessage() {
13 return this.args[0];
14 }
15 /**
16 * Returns the reference to the original RMQ channel.
17 */
18 getChannelRef() {
19 return this.args[1];
20 }
21 /**
22 * Returns the name of the pattern.
23 */
24 getPattern() {
25 return this.args[2];
26 }
27}
28exports.RmqContext = RmqContext;