gistfile1.txt

#include <zmq.h>
#include <stdlib.h>
#include "assert.h"


int main() {
        void *c = zmq_ctx_new();
        assert(c);
        void *s = zmq_socket(c, ZMQ_PUSH);
        assert(s);
        int ret = zmq_connect( s, "tcp://localhost:1234" );
        assert( ret != -1 );


        int hwm = 100;
        zmq_setsockopt( c, ZMQ_SNDHWM, &hwm, sizeof( hwm ) );

        #define SIZE 2097152
        char* buf = malloc(SIZE);
        int i;
        for(i=0; i<SIZE; i++)
                buf[i] = 'A';

        ret = zmq_send(s, buf, SIZE, ZMQ_DONTWAIT);
        assert( ret != -1 );

        zmq_close(s);
        zmq_ctx_destroy(c);
}