public void onMessage()

in wilma-message-search/modules/wilma-message-search-lucene/src/main/java/com/epam/wilma/message/search/jms/FileIndexerQueueListener.java [48:69]

21 lines of code
6 McCabe index (conditional complexity)


    public void onMessage(final Message message) {
        if (message instanceof ObjectMessage) {
            ObjectMessage objectMessage = (ObjectMessage) message;
            try {
                IndexMessage indexMessage = (IndexMessage) objectMessage.getObject();
                String fileName = indexMessage.getFileName();
                String type = indexMessage.getType();
                if (type.equals(IndexingType.ADD.getName())) {
                    luceneEngine.addFileToIndex(fileName);
                } else if (type.equals(IndexingType.DELETE.getName())) {
                    luceneEngine.deleteFileFromIndex(fileName);
                }
            } catch (JMSException e) {
                throw new SystemException("Message information transfer failed. Reason:" + e.getMessage());
            } catch (OutOfMemoryError e) {
                logger.error("HeapMaxMemory:" + Runtime.getRuntime().maxMemory() + ", HeapTotalMemory:" + Runtime.getRuntime().totalMemory()
                        + ", HeapFreeMemory:" + Runtime.getRuntime().freeMemory() + ", Exception: ", e);
                shutdown();
            }

        }
    }