Map> queueMessageMap = new HashMap<>(); for (QueueMessage queueMessage: messages){ queueMessageMap.computeIfAbsent(new JsonObject(queueMessage.getBody()).getString("tenantId"), k -> new LinkedList<>()).add(queueMessage); } for (Map.Entry > tenant: queueMessageMap.entrySet()){ // key = tenant.getKey() // value = tenant.getValue() }



