File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ export class RPCClient {
75
75
exchange : '' ,
76
76
expiration : timeout / 2 ,
77
77
headers : {
78
- "X-Message-Type" : "rpc " ,
78
+ "X-Message-Type" : "request " ,
79
79
'Content-Type' : 'application/json' ,
80
80
} ,
81
81
} ;
Original file line number Diff line number Diff line change @@ -26,7 +26,7 @@ export class RPCListener implements OnModuleInit {
26
26
@MessageHandler ( )
27
27
async onMessage ( { message, headers, raw } : MessageHandleEvent ) {
28
28
29
- if ( headers [ 'X-Message-Type' ] !== 'rpc ' ) {
29
+ if ( headers [ 'X-Message-Type' ] !== 'request ' ) {
30
30
return ;
31
31
}
32
32
@@ -44,6 +44,7 @@ export class RPCListener implements OnModuleInit {
44
44
contentType,
45
45
headers : {
46
46
'Content-Type' : 'application/json' ,
47
+ 'X-Message-Type' : 'response'
47
48
}
48
49
} ;
49
50
You can’t perform that action at this time.
0 commit comments