3. Create instance of the connector using DSL and start publishing and/or consuming messages


       class ExampleResource {
           val connector = connector(role = PublisherAndConsumer) {
               connectionString = "<amqp://guest:guest@localhost:5672/>"
               clientName = "sample-app"
        
               consumer(::sampleProcessingFunction) {
                   workersCoroutineScope = applicationCoroutineScope
                   exchange { name = "some-ref-data" }
                   bindingKey = "refdata.*.user.#"
               }
           }
        
           val publisher = connector.publisher {
               exchange { name = "somedata-exchange" }
               routingKey = "somedata.cool.special"
           }
    
           suspend fun sampleProcessingFunction(message: AmqpMessage<String>): Outcome<AmqpConsumingError, Unit> {
               println(message.payload)
               return Success(Unit)
           }
        
           suspend fun sendSamplePublication(request: String): Outcome<AmqpPublishingError, Unit> =
               publisher(AmqpMessage(request)) 
       }


   See [connector][no.dossier.libraries.amqpconnector.dsl.connector],
   [consumer][no.dossier.libraries.amqpconnector.dsl.consumer],
   [publisher][no.dossier.libraries.amqpconnector.dsl.publisher],
   and [rpcClient][no.dossier.libraries.amqpconnector.dsl.rpcClient] 
   DSL functions for more details and examples