|
@@ -27,7 +27,7 @@ export class ReceiverAdapter extends AdapterBase {
|
|
|
filter((message: GeneralEvent<TransportMessage>) => (message.data as TransportMessage).source === this.adapterProfile.clientId ),
|
|
|
filter((message: GeneralEvent<any>) => message.event === 'New Message'),
|
|
|
).subscribe((message: GeneralEvent<TransportMessage>) => {
|
|
|
- this.console.log({ message: `Received ${(((message.data as TransportMessage).payload as WrappedMessage).payload as FisMessage).header.messageID} from ${((message.data as TransportMessage).target)}`, details: message })
|
|
|
+ this.console.log({ message: `Received ${(((message.data as TransportMessage).payload as WrappedMessage).payload as FisMessage).header.messageID} from ${((message.data as TransportMessage).source)}`, details: message })
|
|
|
observable.next({
|
|
|
id: uuidv4(),
|
|
|
type: `Adapter Event`,
|