docs: @Override
      public void finish(IQueueMessage<ID, DATA> msg) {
          if (!isEphemeralDisabled()) {
              getCollection().deleteOne(Filters.and(Filters.ne(COLLECTION_FIELD_EPHEMERAL_KEY, null),
                      Filters.eq(COLLECTION_FIELD_ID, msg.getId())));
          }
      }