Merge pull request #198 from talien/f/do-not-count-inserted-messages-…

…as-stored modules: Do not count inserted/sent messages as stored ones. This also fixes #142.
syslog-ng · Aug 14, 2014 · a3b894a · a3b894a
2 parents c7caff9 + ba98c91
commit a3b894a
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 3 deletions.
diff --git a/modules/afamqp/afamqp.c b/modules/afamqp/afamqp.c
@@ -465,7 +465,6 @@ afamqp_worker_insert(LogThrDestDriver *s)
 
   if (success)
     {
-      stats_counter_inc(s->stored_messages);
       step_sequence_number(&self->seq_num);
       log_msg_ack(msg, &path_options, AT_PROCESSED);
       log_msg_unref(msg);

diff --git a/modules/afstomp/afstomp.c b/modules/afstomp/afstomp.c
@@ -333,7 +333,6 @@ afstomp_worker_insert(LogThrDestDriver *s)
 
   if (success)
     {
-      stats_counter_inc(self->super.stored_messages);
       step_sequence_number(&self->seq_num);
       log_msg_ack(msg, &path_options, AT_PROCESSED);
       log_msg_unref(msg);

diff --git a/modules/redis/redis.c b/modules/redis/redis.c
@@ -243,7 +243,6 @@ redis_worker_insert(LogThrDestDriver *s)
 
   if (success)
     {
-      stats_counter_inc(self->super.stored_messages);
       step_sequence_number(&self->seq_num);
       log_msg_ack(msg, &path_options, AT_PROCESSED);
       log_msg_unref(msg);