}
String correlationId = jam.getCorrelationId();
SuspendedFiberStorage sfs = deliveryCallback.getRuntimeContext().suspendedFiberStorage;
OutOfOrderMessageException e = new OutOfOrderMessageException(sequence.getId(), message.getMessageNumber());
sfs.resumeFiber(correlationId, e);
} else {
try {
postponedMessageQueue.put(message);
} catch (InterruptedException ex) {
throw LOGGER.logSevereException(new RxRuntimeException(LocalizationMessages.WSRM_1147_ADDING_MSG_TO_QUEUE_INTERRUPTED(), ex));