NewYear - just a simple example.
#include <stdio.h>
#include <stdlib.h>
#include <cmqc.h>
#include <pthread.h>
#include <unistd.h>
static void *dowork(void *arg){
MQHCONN mqconn;
MQLONG CompCode, Reason;
MQCNO Connect_options = {MQCNO_DEFAULT};
MQCONNX("sms", &Connect_options, &mqconn, &CompCode, &Reason);
if(CompCode != MQCC_OK){
fprintf(stderr, "Connection returned %ld\n", (long)Reason);
return NULL;
}
printf("thread %ld connected\n", (long)pthread_self());
sleep(10);
return NULL;
}
int main(){
pthread_attr_t attr;
pthread_t tid;
int i;
if(pthread_attr_init(&attr) != 0){
fprintf(stderr, "could not init attr\n");
exit(1);
}
for(i=0; i<3; ++i){
if(pthread_create(&tid, &attr, dowork, NULL) != 0){
fprintf(stderr, "Could not create thread\n");
exit(1);
}
}
sleep(15);
return 0;
}
cc -I /opt/mqm/inc/ -L /opt/mqm/lib -l mqm -mt test.c
or
gcc -Wall -I /opt/mqm/inc/ -L /opt/mqm/lib -l mqm test.c
and we got
./a.out
thread 3 connected
thread 2 connected
thread 4 connected
rlm_mq got an logical error. I have taken a logic from existing rlm_sql, and just changed SQL stuff to MQ stuff.
This was my mistake :) Ok, will fix.
but MQCONN works in threads as described in the doc.
