@SuppressWarnings("unchecked")
	@Transactional
	public Message<?> atomicProcessing(Message<?> incomingMessage, List<QuerySet> acceptedQuerySetsList, DBAMessageBuilder dbaMessageBuilder) throws QueryExecutorException {
		List<Map<String,Object>> payloadCopy = (List<Map<String, Object>>) incomingMessage.getPayload();
		List<Map<String,Object>> queryResult = null;
		List<Query> queries = acceptedQuerySetsList.get(0).getQueries();
		
		try {
			for (int i = 0; i < MAX_NUMBER_OF_TRIES; i++) {
				for (Query query : queries) {
					queryResult = this.execute(query);
					
					if (queryResult.size() == 1 && query.getType().equals("Query")) {
						
						if (query.getMultiRowResult() == 'N') {
							//Add List of Map containing only ONE MAP to current Map
							//map.put();
							payloadCopy.get(i).put("key", "value");
							
						}
						
					} 
					
				}
				
			}
			
		} catch (Exception e) {
			throw new QueryExecutorException("Error executing query!");
			
		}
		
		return dbaMessageBuilder.buildMessageWith(payloadCopy);
	}