webstomp-client

import webstomp from 'webstomp-client'; import WebSocket from 'ws'; // For Node.js, install 'ws': npm install ws const WEBSOCKET_URL = process.env.STOMP_WS_URL ?? 'ws://localhost:15674/ws'; // Example: RabbitMQ Web-STOMP const STOMP_USER = process.env.STOMP_USER ?? 'guest'; const STOMP_PASS = process.env.STOMP_PASS ?? 'guest'; async function runStompClient() { console.log(`Attempting to connect to STOMP WebSocket at: ${WEBSOCKET_URL}`); // In Node.js, a WebSocket implementation must be explicitly provided to webstomp.over() // The protocols array ensures the WebSocket connection is established with STOMP-compatible subprotocols. const ws = new WebSocket(WEBSOCKET_URL, ['v10.stomp', 'v11.stomp', 'v12.stomp']); const client = webstomp.over(ws, { debug: true, heartbeat: { incoming: 10000, outgoing: 10000 } // Configure heartbeats }); client.connect( { login: STOMP_USER, passcode: STOMP_PASS }, (frame: webstomp.Frame) => { console.log('Successfully connected to STOMP server:', frame.headers['session']); client.subscribe('/queue/example', (message: webstomp.Frame) => { console.log('Received message:', message.body); }, { id: 'my-subscription' }); // Include a unique ID for the subscription console.log('Subscribed to /queue/example'); setTimeout(() => { const messageBody = `Hello from webstomp-client at ${new Date().toISOString()}`; client.send('/queue/example', messageBody, { 'content-type': 'text/plain' }); console.log('Sent message:', messageBody); }, 2000); setTimeout(() => { client.disconnect(() => { console.log('Disconnected from STOMP server.'); ws.close(); }); }, 5000); }, (error: webstomp.Frame | CloseEvent) => { console.error('STOMP connection error:', error); if (error instanceof CloseEvent) { console.error(`WebSocket closed with code ${error.code} and reason: ${error.reason}`); } ws.close(); } ); ws.onopen = () => console.log('WebSocket connection opened.'); ws.onclose = () => console.log('WebSocket connection closed.'); ws.onerror = (err: Event) => console.error('WebSocket error:', err); } runStompClient().catch(console.error);