public void onMessage()

in wilma-application/modules/wilma-core/src/main/java/com/epam/wilma/core/processor/response/jms/ResponseQueueListener.java [58:77]


    public void onMessage(final Message message) {
        if (message instanceof ObjectMessage) {
            try {
                WilmaHttpResponse response = getWilmaHttpResponseFromMessage(message);
                boolean consistentFIDecompressionEnabled = fiDecompressionEnabled;
                if (consistentFIDecompressionEnabled) {
                    messageExtractor.extract(response);
                }
                response.setInputStream(null);
                if (messageLoggingEnabled  && response.isLoggingEnabled()) {
                    jmsTemplate.send(loggerQueue, messageCreatorFactory.create(response, consistentFIDecompressionEnabled));
                }
                manager.tryToSaveResponseIntoSequence(response);
            } catch (JMSException e) {
                throw new SystemException("JMS Exception occurred", e);
            }
        } else {
            throw new IllegalArgumentException("Message must be of type ObjectMessage");
        }
    }