new code_model_flows_processors_queues_DatabaseQueueMessage( queueName, // java.lang.String:String coll, // code.model.flows.processors.queues.DbQueueCollection config, // code.data.O requested, // java.lang.Long:Long timestamp, // scala.Option[java.lang.Long:Long] body, // java.lang.String:String header_set // scala.collection.immutable.Map[java.lang.String:Stringjava.lang.String:String] )