main.nf

#!/usr/bin/env nextflow
import edu.cornell.eipm.messaging.zeromess.messages.*
import edu.cornell.eipm.messaging.zeromess.ZeroMessInitializer

include { SAYHELLOINITALIAN; SAYHELLOINFRENCH; SAYHELLOINSPANISH; SAYHELLOINENGLISH } from './modules/sayHelloLibrary.nf'

/*
========================================================================================
                         Hello Mess Pipeline
========================================================================================
 eipm/hello-mess-nf

 @Homepage / Documentation
 https://github.com/eipm/hello-mess-nf
----------------------------------------------------------------------------------------
*/


log.info """\

    =======================================
      HELLO-MESS-NF   P I P E L I N E
    =======================================

    """.stripIndent()

//initialize the API
ZeroMessInitializer.init(params.pipelineName,
        params.dispatcherURL,
        workflow.sessionId,
        params.pipelineMessagingEnabled)

log.info "Pipeline has started"

workflow SAYHELLOINSEVERALLANGUAGES {
    take:
        welcome
    main:
        welcome | SAYHELLOINITALIAN | SAYHELLOINFRENCH | SAYHELLOINSPANISH | SAYHELLOINENGLISH
    emit:
        SAYHELLOINENGLISH.out.english_file
}

workflow {
    PipelineMessage.started(workflow).forTopic("pipelineEvents")
        .data('message', 'Hope it works').send()

    SAYHELLOINSEVERALLANGUAGES(Channel.fromPath 'welcome.txt')
    SAYHELLOINSEVERALLANGUAGES.out | splitText | view
}

workflow.onComplete {
    log.info "Pipeline completed at: $workflow.complete"
    PipelineMessage.completed(workflow).forTopic("pipelineEvents")
             .data('exit status', 'OK').send()
}