Skip to content

Commit ad9fc19

Browse files
feat: BREAKING CHANGE drop support for amqp config (#30)
1 parent c127ca7 commit ad9fc19

File tree

2 files changed

+1
-44
lines changed

2 files changed

+1
-44
lines changed

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@nestjstools/messaging",
3-
"version": "2.22.0",
3+
"version": "3.0.0",
44
"description": "Simplifies asynchronous and synchronous message handling with support for buses, handlers, channels, and consumers. Build scalable, decoupled applications with ease and reliability.",
55
"author": "Sebastian Iwanczyszyn",
66
"license": "MIT",

src/config.ts

Lines changed: 0 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -71,49 +71,6 @@ export class ChannelConfig {
7171
}
7272
}
7373

74-
/**
75-
* @deprecated Will be removed in version 3.x - use RmqChannelConfig from @nestjstools/messaging-rabbitmq-extension version 2.11+
76-
*/
77-
export class AmqpChannelConfig extends ChannelConfig {
78-
public readonly connectionUri: string;
79-
public readonly exchangeName: string;
80-
public readonly exchangeType: ExchangeType;
81-
public readonly queue: string;
82-
public readonly bindingKeys?: string[];
83-
public readonly autoCreate?: boolean;
84-
public readonly deadLetterQueueFeature?: boolean;
85-
86-
constructor({
87-
name,
88-
connectionUri,
89-
exchangeName,
90-
exchangeType,
91-
queue,
92-
enableConsumer,
93-
bindingKeys,
94-
autoCreate,
95-
deadLetterQueueFeature,
96-
avoidErrorsForNotExistedHandlers,
97-
middlewares,
98-
normalizer,
99-
}: AmqpChannelConfig) {
100-
super(
101-
name,
102-
avoidErrorsForNotExistedHandlers,
103-
middlewares,
104-
enableConsumer,
105-
normalizer,
106-
);
107-
this.connectionUri = connectionUri;
108-
this.exchangeName = exchangeName;
109-
this.exchangeType = exchangeType;
110-
this.queue = queue;
111-
this.bindingKeys = bindingKeys;
112-
this.autoCreate = autoCreate ?? true;
113-
this.deadLetterQueueFeature = deadLetterQueueFeature ?? false;
114-
}
115-
}
116-
11774
export class InMemoryChannelConfig extends ChannelConfig {
11875
constructor({
11976
name,

0 commit comments

Comments
 (0)