new code_model_flows_processors_azure_serviceBus_AzureServiceBusSubscriber( connectionString, // java.lang.String queueName, // java.lang.String callBack, // scala.Function1[Unitscala.util.Either[code.data.queues.QueueMessagejava.lang.Throwable]] implicitAck, // boolean )