- log.error("Could not place order {}: {}", transfer, exception.toString());
- result.setErrorResult(exception);
- return;
+ log.debug("Sent {} to {}/{}:{}", transfer, metadata.topic(), metadata.partition(), metadata.offset());
+ repository.update(transfer.getId(), SENT, PENDING);
+ }
+ else
+ {
+ log.error("Could not send {}: {}", transfer, exception.getMessage());
+ repository.update(transfer.getId(), SENT, FAILED);