Struct tapa_cgloop_nats::CGLoop

pub struct CGLoop {
    pub url: String,
    pub source_topic: String,
    pub success_topic: String,
    pub failure_topic: String,
    pub group: String,
    pub unsub_on_exit: bool,
    pub timeout: Duration,
}

Fields

url: String

source_topic: String

success_topic: String

failure_topic: String

group: String

unsub_on_exit: bool

timeout: Duration

Implementations

impl CGLoop

pub fn new(
    url: &str,
    source_topic: &str,
    success_topic: &str,
    failure_topic: &str,
    group: &str,
    unsub_on_exit: bool,
    timeout: Option<Duration>
) -> Self

pub async fn run(
    self,
    options: NatsOptions,
    shutdown_flag: Arc<AtomicBool>,
    on_message: Box<dyn NatsMessageHandler>
) -> AnyResult<()>