Ошибки при публикации сообщений в Amazon Queue с использованием доступных библиотек узлов js - PullRequest
Новая
       72

Ошибки при публикации сообщений в Amazon Queue с использованием доступных библиотек узлов js

0 голосов
/ 11 декабря 2018

Я пытаюсь опубликовать сообщения в Amazon MQ от Node JS, и ни одна из библиотек, которые я пробовал до сих пор, похоже, не работает.

Библиотека 1: 

stomp-client

Код: 

var Stomp = require('stomp-client');
var destination = '/topic/{new_topic}';
var client = new Stomp('{prefix}.amazonaws.com', 
    61614, 
    '{user}', 
    '{password}');

client.connect(function(sessionId) {
    client.publish(destination, 'Oh herrow');
});

Ошибка при первой библиотеке: 

Emitted 'error' event at:
    at StompFrameEmitter.<anonymous> (project_path\node_modules\stomp-client\lib\client.js:236:10)
    at StompFrameEmitter.emit (events.js:182:13)
    [... lines matching original stack trace ...]
    at Socket.Readable.push (_stream_readable.js:219:10)

Библиотека 2: 

stompit

Код: 

const stompit = require('stompit');

var connectOptions = {
  'host': '{prefix}.amazonaws.com',
  'port': 61614,
  'connectHeaders':{
    'host': '/',
    'login': '{user}',
    'passcode': '{password}',
    'heart-beat': '5000,5000'
  }
};

stompit.connect(connectOptions, function(error, client) {

  if (error) {
    console.log('connect error ' + error.message);
    return;
  }

  var sendHeaders = {
    'destination': '/topic/{new_topic}',
    'content-type': 'text/plain'
  };

  var frame = client.send(sendHeaders);
  frame.write('hello');
  frame.end();

});

Ошибка со второй библиотекой: connect error unexpected end of stream

Я не уверен, что еще я могу попробовать, но я застрял здесь как сообщения об ошибкахдаже не многословный плюс нет много информации по этому вопросу в Интернете.

Только соответствующая статья, которую я нашел, не имеет ответа на форуме Amazon: https://forums.aws.amazon.com/thread.jspa?messageID=831730&tstart=0

...