need to send individual message to client about stompbrokerjs HOT 5 CLOSED

ok, I made two things:

1. add socket param to emit of 'send' event line 112 in original stompServer.js:
   this.emit('send', {frame: {headers: frame.headers, body: bodyObj}, dest: args.dest, socket});

2. add following func to original stompServer.js

/** SendIndividual message to specific client

• @param {socket} client
• @param {object} headers Message headers
• @param {string} body Message body */
  this.sendIndividual = function (socket, topic, headers, body) {
  var _headers = {};
  if (headers) {
  for (var key in headers) {
  _headers[key] = headers[key];
  }
  }
  var frame = {
  body: body,
  headers: _headers
  };
  var args = {
  dest: topic,
  frame: this.frameParser(frame)
  };

var bodyObj = args.frame.body;
var frame = this.frameSerializer(args.frame);
var headers = { //default headers
  'message-id': stomp.genId("msg"),
  'content-type': 'text/plain'
};
if (frame.body !== undefined) {
  if (typeof frame.body !== 'string')
    throw "Message body is not string";
  frame.headers["content-length"] = frame.body.length;
}
if (frame.headers) {
  for (var key in frame.headers) {
    headers[key] = frame.headers[key];
  }
}

for (var i in this.subscribes) {
  var sub = this.subscribes[i];
  if (socket.sessionId !== sub.sessionId) {
    continue;
  }
  var match = this._checkSubMatchDest(sub, args);
  if (match) {
    args.frame.headers.subscription = sub.id;
    frame.command = "MESSAGE";
    if (socket !== undefined) {
      StompUtils.sendFrame(socket, frame);
    }
  }
}

};

Usage: In my project I needed only to reply to individuals:

stompServer.on('send', (ev) => {
//...
stompServer.sendIndividual(ev.socket, TOPIC_NAME, {}, REPLY_TEXT);
});

the same code for reply on subscribe:

stompServer.on('subscribe', (ev) => {
//...
stompServer.sendIndividual(ev.socket, TOPIC_NAME, {}, REPLY_TEXT);
});

from stompbrokerjs.

I figured out how to do it

from stompbrokerjs.

@krtl Could you please share how you did it?

from stompbrokerjs.

from stompbrokerjs.

@krtl Will you be able to share any code snippets or the general idea/login on what changes you made, just an overview

from stompbrokerjs.