Subscribes to the 'example' node and prints the message bodies received.
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
typedef char str[1024];
typedef struct app_data_t {
str address;
str container_id;
int message_count;
int received;
bool finished;
} app_data_t;
static const int BATCH = 100;
static int exit_code = 0;
exit_code = 1;
}
}
#define MAX_SIZE 1024
static char buffer[MAX_SIZE];
ssize_t len;
if (len > 0) {
pn_string_t *s = pn_string(NULL);
printf("%s\n", pn_string_get(s));
pn_free(s);
}
}
}
}
static void handle(app_data_t* app,
pn_event_t* event) {
pn_link_flow(l, app->message_count ? app->message_count : BATCH);
} break;
decode_message(dlv);
if (app->message_count == 0) {
}
} else if (++app->received >= app->message_count) {
printf("%d messages received\n", app->received);
}
}
} break;
break;
break;
break;
break;
app->finished = true;
break;
default: break;
}
}
static void usage(const char *arg0) {
fprintf(stderr, "Usage: %s [-a url] [-m message-count]\n", arg0);
exit(1);
}
int main(int argc, char **argv) {
app_data_t app = {{0}};
app.message_count = 100;
const char* urlstr = NULL;
int opt;
while((opt = getopt(argc, argv, "a:m:")) != -1) {
switch(opt) {
case 'a': urlstr = optarg; break;
case 'm': app.message_count = atoi(optarg); break;
default: usage(argv[0]); break;
}
}
if (optind < argc)
usage(argv[0]);
snprintf(app.container_id, sizeof(app.container_id), "%s:%d", argv[0], getpid());
const char *host = url ? pn_url_get_host(url) : NULL;
const char *port = url ? pn_url_get_port(url) : "amqp";
strncpy(app.address, (url && pn_url_get_path(url)) ? pn_url_get_path(url) : "example", sizeof(app.address));
do {
handle(&app, e);
}
} while(!app.finished);
free(app.message_buffer.start);
return exit_code;
}