@@ -16,7 +16,11 @@ export default class DailyMessage {
16
16
async listen ( ) {
17
17
console . log ( this . client . cluster . count ) ;
18
18
const URL = process . env . RABBITMQ_URL || "fallback" ;
19
- const connection = await amqplib . connect ( URL , { clientProperties : { connection_name : `client-cluster-${ this . client . cluster . id } ` } } ) ;
19
+ const connection = await amqplib . connect ( URL , {
20
+ clientProperties : {
21
+ connection_name : `client-cluster-${ this . client . cluster . id } ` ,
22
+ } ,
23
+ } ) ;
20
24
let QUEUE = `cluster-${ this . client . cluster . id } ` ;
21
25
if ( connection ) {
22
26
const channel = await connection . createChannel ( ) ;
@@ -73,7 +77,7 @@ export default class DailyMessage {
73
77
message : IQueueMessage ,
74
78
properties : MessageProperties ,
75
79
) : Promise < Result < string > > {
76
- console . log ( message )
80
+ console . log ( message ) ;
77
81
if ( message . channelId == null ) {
78
82
return {
79
83
success : false ,
@@ -210,7 +214,7 @@ export default class DailyMessage {
210
214
reason : string ,
211
215
message : amqplib . Message ,
212
216
) {
213
- const headers = { rejectionCause : reason , cluster : this . client . cluster . id } ;
217
+ const headers = { rejectionCause : reason , cluster : this . client . cluster . id } ;
214
218
channel . publish ( "DLX" , "key" , message . content , {
215
219
headers : headers ,
216
220
messageId : message . properties . messageId ,
0 commit comments