Sending Stomp messages, the brute force way

I had to send out Stomp Messages to ActiveMQ at 100 Messages per second. In Python.
Leaving out all the framework stuff, this ugly code takes less than 0.001s per message.
Ugly, but works.

import socket

HOST = 'localhost'
PORT = 61613

# Minimal Stomp sending without any error checking
def send_message_brute_force(msg, dest):
    """Send msg to dest."""
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.connect((HOST, PORT))
    sock.send('CONNECTnnx00n')
    if 'x00' in msg:
        sock.send('SENDndestination: %sncontent-length:%dnn%sx00n' % (dest, len(msg), msg))
    else:
        sock.send('SENDndestination: %snn%sx00n' % (dest, msg))
    sock.send('DISCONNECTnx00n')

send_message_brute_force('TESTING', '/queue/FOO/BAR')

Kommentar verfassen

Trage deine Daten unten ein oder klicke ein Icon um dich einzuloggen:

WordPress.com-Logo

Du kommentierst mit Deinem WordPress.com-Konto. Abmelden / Ändern )

Twitter-Bild

Du kommentierst mit Deinem Twitter-Konto. Abmelden / Ändern )

Facebook-Foto

Du kommentierst mit Deinem Facebook-Konto. Abmelden / Ändern )

Google+ Foto

Du kommentierst mit Deinem Google+-Konto. Abmelden / Ändern )

Verbinde mit %s