new code_model_flows_processors_google_pubsub_PubSubQueueMessage( config, // code.data.O requested, // java.lang.Long:Long timestamp, // scala.Option[java.lang.Long:Long] messageId, // java.lang.String:String body, // java.lang.String:String headers, // scala.collection.immutable.Map[java.lang.String:Stringjava.lang.String:String] acker, // scala.Option[scala.Function0[code.model.flows.processors.queues.QueueMessageResponse]] nacker, // scala.Option[scala.Function0[code.model.flows.processors.queues.QueueMessageResponse]] rejecter // scala.Option[scala.Function0[code.model.flows.processors.queues.QueueMessageResponse]] )