diff --git a/packages/core/src/transport/WsOutboundTransport.ts b/packages/core/src/transport/WsOutboundTransport.ts index ff6dabda8e..18a4eda3a9 100644 --- a/packages/core/src/transport/WsOutboundTransport.ts +++ b/packages/core/src/transport/WsOutboundTransport.ts @@ -47,8 +47,9 @@ export class WsOutboundTransport implements OutboundTransport { throw new AriesFrameworkError("Missing connection or endpoint. I don't know how and where to send the message.") } - const isNewSocket = !this.hasOpenSocket(endpoint) - const socket = await this.resolveSocket({ socketId: endpoint, endpoint, connectionId }) + const socketId = `${endpoint}-${connectionId}` + const isNewSocket = !this.hasOpenSocket(socketId) + const socket = await this.resolveSocket({ socketId, endpoint, connectionId }) socket.send(Buffer.from(JSON.stringify(payload)))