0
const tibems = require('tibems');
// Define the EMS server connection info
const serverUrl = 'tcp://localhost:7222'; // Replace with your EMS server URL
const username = 'yourUsername';
const password = 'yourPassword';
const emsConnection = new tibems.TibemsConnection(serverUrl, username, password);
emsConnection.connect((err) => {
if (err) {
console.error('Error connecting to EMS server:', err);
return;
}
console.log('Connected to EMS server');
const session = emsConnection.createSession(tibems.TibemsSession.AUTO_ACKNOWLEDGE);
const destination = session.createQueue('yourQueueName');
const producer = session.createProducer(destination);
const consumer = session.createConsumer(destination);
// Send a message to the queue
const messageToSend = session.createTextMessage('Hello, Tibco EMS!');
producer.send(messageToSend, (err) => {
if (err) {
console.error('Error sending message:', err);
} else {
console.log('Message sent to the queue');
}
// Receive a message from the queue
consumer.receive((err, messageReceived) => {
if (err) {
console.error('Error receiving message:', err);
} else {
console.log('Received message:', messageReceived.getText());
}
producer.close();
consumer.close();
session.close();
emsConnection.close();
});
});
});
