[][src]Function graph_generator_lib::default_consumer

pub fn default_consumer<ProcErr>(
    queue_url: String,
    sqs_completion_handler: SqsCompletionHandlerActor<Graph, ProcErr>,
    region: Region,
    consume_policy: ConsumePolicy,
    shutdown_tx: Sender<()>
) -> SqsConsumerActor where
    ProcErr: Debug + Send + Sync + Clone + 'static,