diff --git a/src/messaging/MessagingEvent.ts b/src/messaging/MessagingEvent.ts index 314cb296..504a79f4 100644 --- a/src/messaging/MessagingEvent.ts +++ b/src/messaging/MessagingEvent.ts @@ -148,7 +148,8 @@ export default class MessagingEvent { } globalSubscriptionCounter++; - return MessagingService.SubscribeAsync(this.name, (recieved: ISubscriptionMessage) => { + return MessagingService.SubscribeAsync(this.name, (data, sent) => { + const recieved = { Data: data, Sent: sent }; const { Sent } = recieved; if (isJobTargetMessage(recieved)) {