#include <stdio.h>
#include <stdlib.h>
typedef struct app_data_t {
const char *host, *port;
const char *amqp_address;
const char *container_id;
int message_count;
int sent;
int acknowledged;
} app_data_t;
static int exit_code = 0;
exit_code = 1;
}
}
static void send_message(app_data_t* app,
pn_link_t *sender) {
exit(1);
}
}
static bool handle(app_data_t* app,
pn_event_t* event) {
{
break;
}
}
while (
pn_link_credit(sender) > 0 && app->sent < app->message_count) {
++app->sent;
send_message(app, sender);
}
break;
}
if (++app->acknowledged == app->message_count) {
printf("%d messages sent and acknowledged\n", app->acknowledged);
}
} else {
exit_code=1;
}
break;
}
break;
break;
break;
break;
return false;
default: break;
}
return true;
}
void run(app_data_t *app) {
do {
if (!handle(app, e)) {
return;
}
}
} while(true);
}
int main(int argc, char **argv) {
struct app_data_t app = {0};
app.container_id = argv[0];
app.host = (argc > 1) ? argv[1] : "";
app.port = (argc > 2) ? argv[2] : "amqp";
app.amqp_address = (argc > 3) ? argv[3] : "examples";
app.message_count = (argc > 4) ? atoi(argv[4]) : 10;
run(&app);
free(app.message_buffer.start);
return exit_code;
}