ark::pipeline::SerializableSubscriber

Defined in header “ark/pipeline/serializable_subscriber.hh”.

---

A wrapper over a standard subscriber that provides functionality related to communicating message type name and schema. Use this for when you are subscribing to an envelope, but realize that the type is serializable, and can further communicate that type information.

Methods

• SerializableSubscriber(SubscriberConfiguration< AbstractEnvelope > config, std::string message_type_name, std::string message_schema, std::string message_schema_protocol)
  Constructor. Initializes the subscriber with the given parameters.

• ~SerializableSubscriber()
  Virtual destructor for cleanup.

• bool consumes_type(const std::type_info & type)
  Returns true if this subscriber can execute messages of the given type or not.

• bool message_is_serializable()
  Returns true if the message type for this subscriber is serializable.

• std::string message_type_name()
  Returns the message type name of the object that flows over this subscriber.

• std::string message_schema_registry()
  Returns the schema for the object that flows over this subscriber, if available.

• std::string message_schema_protocol()
  Returns the schema protocol (rbuf, proto, etc) for the object that flows over this subscriber, if available.