High-Performance
Message Queue

version: '3.8'

services:
  malachimq:
    image: hectorcardoso/malachimq:latest
    ports:
      - "4040:4040"  # Broker
      - "4041:4041"  # Dashboard
    environment:
      - MALACHIMQ_ADMIN_PASS=secure_password
      - MALACHIMQ_LOCALE=en_US

const net = require('net');

const client = net.createConnection(4040, 'localhost', () => {
  // Authenticate
  client.write(JSON.stringify({
    action: 'auth',
    username: 'producer',
    password: 'producer123'
  }) + '\n');
});

let authenticated = false;

client.on('data', (data) => {
  const response = JSON.parse(data.toString().trim());
  
  if (!authenticated && response.s === 'ok' && response.token) {
    authenticated = true;
    // Send message
    client.write(JSON.stringify({
      action: 'publish',
      queue_name: 'my-queue',
      payload: { hello: 'world' }
    }) + '\n');
  } else if (authenticated && response.s === 'ok') {
    console.log('Message sent successfully!');
    client.end();
  } else if (response.s === 'err') {
    console.error('Error:', response.reason);
    client.end();
  }
});