// Copyright 2020-2025 Jeisson Hidalgo-Cespedes. ECCI-UCR. CC BY 4.0
#pragma once

#include "Consumer.hpp"
#include "Packet.hpp"

/**
 * @brief A PacketConsumer class example
 */
class PacketConsumer : public Consumer<Packet> {
  DISABLE_COPY(PacketConsumer);

 protected:
  /// Delay of consumer to consume a package, negative for max random
  int consumerDelay = 0;
  /// Number of messages received
  size_t receivedMessages = 0;

 public:
  /// Constructor
  explicit PacketConsumer(int consumerDelay);
  /// Consume the messages in its own execution thread
  int run() override;
  /// Override this method to process any data extracted from the queue
  void consume(Packet data) override;
};