private void start()

in main/src/search-service/search/src/main/java/com/bioimage/search/App.java [145:215]
69 lines of code
11 McCabe index (conditional complexity)

    private void start() {
		int i=0;
		int receiveCount=0;
		long ts0 = 0;
		long ts1 = 0;
		long ts2 = 0;
		long ts3 = 0;
		List<Long> ts0gapList = new ArrayList<>();
		while(true) {
			long ts0new = new Date().getTime();
			long ts0gap = ts0new - ts0;
			ts0 = ts0new;
			ts0gapList.add(ts0gap);
			if (i%100==0) {
				String logEntry="";
		    	logEntry += "Region="+REGION+" Count v10 =" + i + "\n";
		    	for (long g : ts0gapList) {
		    		logEntry += "ts0gap: " + g + "\n";
		    	}
		    	ts0gapList.clear();
		    	System.out.println(logEntry);
			}
			List<Message> managementMessages = null;
			List<Message> searchMessages = null;
	    	try {
	            ReceiveMessageRequest receiveManagementRequest = ReceiveMessageRequest.builder()
	                .queueUrl(MANAGEMENT_QUEUE_URL)
	                .build();
	            managementMessages = sqsClient.receiveMessage(receiveManagementRequest).messages();
	            for (Message m : managementMessages) {
	            	try {
	            		receiveCount++;
						handleManagementMessage(m);
	            	} catch (Exception ex) {
	            		ex.printStackTrace();
	            		updateStatusToError(m);
	            	}
	            }

	            ReceiveMessageRequest receiveSearchRequest = ReceiveMessageRequest.builder()
	                .queueUrl(SEARCH_QUEUE_URL)
	                .build();
	            searchMessages = sqsClient.receiveMessage(receiveSearchRequest).messages();
	            for (Message m : searchMessages) {
	            	try {
	            		receiveCount++;
						handleSearchMessage(m);
	            	} catch (Exception ex) {
	            		ex.printStackTrace();
	            		updateStatusToError(m);
	            	}
	            }
	            
	    	} catch (Exception ex) {
				ex.printStackTrace();
	    	}
	    	try {
	            deleteMessages(managementMessages, MANAGEMENT_QUEUE_URL);
	            deleteMessages(searchMessages, SEARCH_QUEUE_URL);
	            if (receiveCount==0) {
		            TimeUnit.SECONDS.sleep(1);
	            } else {
					System.out.println("ReceiveCount="+receiveCount);
	            }
	    	} catch (Exception ex) {
	    		ex.printStackTrace();
	    	}
	    	receiveCount=0;
	    	i+=1;
		}
    }