File tree Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Expand file tree Collapse file tree 1 file changed +8
-7
lines changed Original file line number Diff line number Diff line change @@ -95,19 +95,20 @@ export class GCPSConsumer implements Process {
95
95
await Promise . all (
96
96
messages . map ( async ( m ) => {
97
97
if ( m . message . attributes === undefined ) {
98
- if ( this . logger ) {
99
- this . logger . info (
100
- `[GCPS - TASK - START] Event discarded due to corrupted attributes.`
101
- )
102
- }
98
+ if ( this . logger ) {
99
+ this . logger . info (
100
+ `[GCPS - TASK - START] Event discarded due to corrupted attributes.`
101
+ )
102
+ }
103
103
104
- return this . ack ( m . ackId )
104
+ return this . ack ( m . ackId )
105
105
}
106
106
107
107
return this . executeTask (
108
108
m . ackId ,
109
109
{
110
- eventName : m . message . attributes . STRONTIUM_EVENT_NAME ,
110
+ eventName :
111
+ m . message . attributes . STRONTIUM_EVENT_NAME ,
111
112
message : m . message . data ,
112
113
} ,
113
114
container
You can’t perform that action at this time.
0 commit comments