ark::pipeline::SynchronizedMessageSet

Defined in header “ark/pipeline/stages/synchronized_message_set.hh”.

---

Publishes from the synchronized message set publisher, this contains all of the messages that were ‘synchronized’ together.

Methods

• std::shared_ptr< const MessageType > payload(const std::string & channel_name)
  A convenience function to return the message contents based on channel name.

Variables

• uint64_t sequence_number= 0
  Sequence identifier (will increment each time this set is published).

• std::map< std::string, AbstractEnvelopeCPtr > envelopes
  The envelopes in the synchronized set, organized by channel name.