Difference between revisions of "Truxton etl set queue name"
Jump to navigation
Jump to search
(→Sample) |
(→Sample) |
||
| Line 53: | Line 53: | ||
message = truxton_etl_get_message( app ); | message = truxton_etl_get_message( app ); | ||
} | } | ||
| − | |||
truxton_etl_destroy( app ); | truxton_etl_destroy( app ); | ||
} | } | ||
</source> | </source> | ||
Latest revision as of 11:27, 10 February 2021
This tells Truxton which message queue to wait for messages for this ETL.
Syntax
void truxton_etl_set_queue_name( uint64_t etl_handle, char const * name );
Parameters
etl_handle
The handle created by the truxton_etl_create call.
name
A short human readable string that will be used as the message queue name.
Remarks
This name will be normalized to all lower case letters with spaces removed. "My Queue" will be normalized to "myqueue"
Sample
#include <TruxtonCAPI.h>
void main( void )
{
char file_id[ 65 ];
char description[ 128 ];
uint64_t message = 0;
uint64_t app = truxton_etl_create();
truxton_etl_set_application_name( app, "Sample C ETL" );
truxton_etl_set_depot_type_name( app, "custom" );
truxton_etl_set_queue_name( app, "SampleC" );
truxton_etl_set_description( app, "A sample of how to write an ETL");
truxton_etl_get_description( app, description, sizeof(description));
// Pause here until we get a message from the "SampleC" message queue
message = truxton_etl_get_message( app );
while( message != 0 )
{
// Do something with the message
memset( file_id, 0x00, sizeof( file_id ) );
truxton_message_get_file_id( message, file_id, sizeof( file_id ) );
printf( "Received file id %s\n", file_id );
truxton_message_destroy( message );
// Pause here until we get another message from the "SampleC" message queue
message = truxton_etl_get_message( app );
}
truxton_etl_destroy( app );
}