new code_model_flows_processors_queues_ImQueueMessage( qm, // code.model.flows.processors.queues.QueueMessage batchId // scala.Option[java.lang.String:String] )