NewSource creates new instance of the Source.

Parse maps the incoming map to the Config and validates it.

ConfigKeyAckPolicy is a config name for a message acknowledge policy.

ConfigKeyBufferSize is a config name for a buffer size.

ConfigKeyDeliverPolicy is a config name for a message deliver policy.

ConfigKeyDeliverSubject is a config name for a deliver subject.

ConfigKeyDurable is a config name for a durable name.

Config holds source specific configurable values.

Source operates source logic.