Allow delete messages option after acknowledge (#12)

* Allow delete message after acknowledge

* Update Readme

* Create node package

* Revert name of package

* Change option name to deleteMessagesAfterAck

* Update Readme

Author: nicoalonso

README.md

@@ -97,6 +97,7 @@ async function bootstrap() {
         block: 5000,
         consumer: 'users-1',
         consumerGroup: 'users',
+        deleteMessagesAfterAck: true,  // optional: delete message from stream
       },
       // optional. See our example main.ts file for more details...
       // serialization: {},

lib/interfaces.ts

@@ -15,6 +15,7 @@ interface RedisStreamOptionsXreadGroup {
   block?: number;
   consumerGroup: string;
   consumer: string;
+  deleteMessagesAfterAck?: boolean;
 }
 
 export type RedisStreamOptions = RedisStreamOptionsXreadGroup;

lib/redis.server.ts

@@ -153,6 +153,13 @@ export class RedisStreamStrategy
         inboundContext.getMessageId(),
       );
 
+      if (true === this.options?.streams?.deleteMessagesAfterAck) {
+        await this.client.xdel(
+          inboundContext.getStream(),
+          inboundContext.getMessageId(),
+        );
+      }
+
       return true;
     } catch (error) {
       this.logger.error(error);