in main.c [36:83]
int main(int argc, char *argv[])
{
apr_status_t rc;
amqcs_connection *connection;
apr_pool_t *pool;
amqcs_connect_options connect_options;
memset(&connect_options, 0, sizeof(connect_options));
strcpy(connect_options.hostname, "127.0.0.1");
connect_options.port = 61616;
setbuf(stdout, NULL);
rc = apr_initialize();
if( rc!=APR_SUCCESS )
return rc;
atexit(terminate);
rc = apr_pool_create(&pool, NULL);
rc==APR_SUCCESS || die(-2, "Could not allocate pool", rc);
fprintf(stdout, "Connecting......");
rc=amqcs_connect( &connection, &connect_options, pool);
rc==APR_SUCCESS || die(-2, "Could not connect", rc);
fprintf(stdout, "OK\n");
fprintf(stdout, "Sending message.");
{
char *buffer = "Hello World!";
ow_ActiveMQQueue *dest;
ow_ActiveMQTextMessage *message = ow_ActiveMQTextMessage_create(pool);
message->content = ow_byte_array_create_with_data(pool,sizeof(buffer),buffer);
dest = ow_ActiveMQQueue_create(pool);
dest->physicalName = ow_string_create_from_cstring(pool,"TEST.QUEUE");
rc = amqcs_send(connection, (ow_ActiveMQDestination*)dest, (ow_ActiveMQMessage*)message, 1,4,0,pool);
rc==APR_SUCCESS || die(-2, "Could not send message", rc);
}
fprintf(stdout, "OK\n");
fprintf(stdout, "Disconnecting...");
rc=amqcs_disconnect(&connection);
rc==APR_SUCCESS || die(-2, "Could not disconnect", rc);
fprintf(stdout, "OK\n");
apr_pool_destroy(pool);
return 0;
}