-
Notifications
You must be signed in to change notification settings - Fork 35
Open
Description
Oddly, this has cropped up when testing on another environment.
ActiveMQ is up, and the Queue exists. I also opened the Stompit port for inbound traffic.
Works fine when testing on one environment, but not a new one. Code is the same, I've compared it using BeyondCompare.
stompAsync = async (index: number, url: string, title?: string) => {
return new Promise<void>((resolve, reject) => {
stompit.connect({
host: `${process.env.MQ_ID}-1.mq.eu-west-1.amazonaws.com`,
port: 61614,
ssl: true,
connectHeaders: {
'login': 'xxx',
'passcode': 'yyy',
},
}, (error: any, client: any) => {
if (error) {
reject(error);
}
let frame = client.send({ destination: 'TestQueue', AMQ_SCHEDULED_DELAY: index * 1000 }); // fails here
frame.write(JSON.stringify({index: index, title: title, url: url, timeSent: new Date()}));
frame.end();
client.disconnect();
resolve();
});
});
};s-badran
Metadata
Metadata
Assignees
Labels
No labels