new code_model_flows_processors_azure_serviceBus_AzureServiceBusSubscriber( connectionString, // java.lang.String:String queueName, // java.lang.String:String callBack, // scala.Function1[scala.Unit:Unitscala.util.Either[code.model.flows.processors.queues.QueueMessagejava.lang.Throwable]] implicitAck // java.lang.Boolean:Boolean )