diff options
author | Thomas White <taw@physics.org> | 2024-04-29 16:04:29 +0200 |
---|---|---|
committer | Thomas White <taw@physics.org> | 2024-04-29 16:04:29 +0200 |
commit | b62a4d1ff2e7ae19591a0501e35aadbd6eaaf472 (patch) | |
tree | 60103ab6e73449718f8a254942b8271b5c2d6be6 /src/im-asapo.c | |
parent | aecd2dcd9af71911ce0b2be0ac74c1820c02f3f7 (diff) |
indexamajig: Report ASAP::O message ID for acknowledgement
Something strange is going on here, need to debug.
Diffstat (limited to 'src/im-asapo.c')
-rw-r--r-- | src/im-asapo.c | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/im-asapo.c b/src/im-asapo.c index 6df14e93..014c4774 100644 --- a/src/im-asapo.c +++ b/src/im-asapo.c @@ -278,6 +278,7 @@ void im_asapo_finalise(struct im_asapo *a, uint64_t message_id) AsapoErrorHandle err = asapo_new_handle(); asapo_consumer_acknowledge(a->consumer, a->group_id, message_id, a->stream, &err); + STATUS("Acknowledging ASAP::O message %lli\n", (long long int)message_id); if ( asapo_is_error(err) ) { show_asapo_error("Couldn't acknowledge ASAP::O message", err); } |