1 | ;
|
2 | Object.defineProperty(exports, "__esModule", { value: true });
|
3 | exports.SubscribeMessage = void 0;
|
4 | const constants_1 = require("../constants");
|
5 | /**
|
6 | * Subscribes to messages that fulfils chosen pattern.
|
7 | */
|
8 | const SubscribeMessage = (message) => {
|
9 | return (target, key, descriptor) => {
|
10 | Reflect.defineMetadata(constants_1.MESSAGE_MAPPING_METADATA, true, descriptor.value);
|
11 | Reflect.defineMetadata(constants_1.MESSAGE_METADATA, message, descriptor.value);
|
12 | return descriptor;
|
13 | };
|
14 | };
|
15 | exports.SubscribeMessage = SubscribeMessage;
|