public static List<Message> processMessage(String input) throws QueueNotFoundException{
		System.out.println("************************************");
		System.out.println("Client received : "+input);
		Message msg = null;
		String topic = null;
		try {
			msg = new Message(input);
			topic = msg.topic();
		} catch (JSONException e) {
			e.printStackTrace();
		}
		MBusQueue queue = MBusQueueFactory.getQueue(topic);
		if(queue != null){
			if(msg.containsKey(Constants.MESSAGEBUS_COMMAND)){
				try {
					if(msg.get(Constants.MESSAGEBUS_COMMAND) != null && msg.get(Constants.MESSAGEBUS_COMMAND).equalsIgnoreCase(Constants.FETCH_MESSAGE)){
						return queue.fetch(10);
					}
				} catch (JSONException e) {
					e.printStackTrace();
				}
			}else{
				queue.add(msg);
			}	
		}
		System.out.println("************************************");
		return null;
	}