int main()

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;
}