kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #588 in FS/freeswitch from ~ANDEE/freeswitch:bugfix/FS-8432-wrong-timestamp-resolution-in-mpd_amqp to master 

* commit '8c540c6632fc083b551c7e4966d72ad79b2ed0b4':
  FS-8432 fixes timestamp type resolution, adds new header of type uint64 to carry microsecond resolution timestamp
This commit is contained in:
William King 2015-12-23 18:44:22 -06:00
parent cdf0e32921 8c540c6632
commit 65255fc8b0
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mod/event_handlers/mod_amqp/mod_amqp_producer.c
View File

@ -391,9 +391,10 @@ switch_status_t mod_amqp_producer_create(char *name, switch_xml_t cfg)
/* This should only be called in a single threaded context from the producer profile send thread */
switch_status_t mod_amqp_producer_send(mod_amqp_producer_profile_t *profile, mod_amqp_message_t *msg)
{
amqp_table_entry_t messageTableEntries[1];
amqp_table_entry_t messageTableEntries[2];
amqp_basic_properties_t props;
int status;
uint64_t timestamp;
if (! profile->conn_active) {
/* No connection, so we can not send the message. */
@ -415,9 +416,13 @@ switch_status_t mod_amqp_producer_send(mod_amqp_producer_profile_t *profile, mod
props.timestamp = (uint64_t)time(NULL);
props.headers.num_entries = 1;
props.headers.entries = messageTableEntries;
timestamp = (uint64_t)switch_micro_time_now();
messageTableEntries[0].key = amqp_cstring_bytes("x_Liquid_MessageSentTimeStamp");
messageTableEntries[0].value.kind = AMQP_FIELD_KIND_TIMESTAMP;
messageTableEntries[0].value.value.u64 = (uint64_t)switch_micro_time_now();
messageTableEntries[0].value.value.u64 = (uint64_t)(timestamp / 1000000);
messageTableEntries[1].key = amqp_cstring_bytes("x_Liquid_MessageSentTimeStampMicro");
messageTableEntries[1].value.kind = AMQP_FIELD_KIND_U64;
messageTableEntries[1].value.value.u64 = timestamp;
}
status = amqp_basic_publish(