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");
}
}