@Override
- public synchronized void store(Transfer transfer)
- {
- Optional
- .ofNullable(map.get(transfer.getId()))
- .ifPresentOrElse(
- json ->
- {
- throw new IllegalArgumentException("Could not overwrite " + json + " with " + transfer);
- },
- () -> put(transfer));
- }
-
- private void put(Transfer transfer)
+ public void store(Transfer transfer)
{
try
{
}
catch (JsonProcessingException e)
{
- log.error("Could not convert Transfer.class: {}", transfer, e);
+ throw new RuntimeException(e);
}
}
@Override
- public synchronized Optional<Transfer> get(Long id)
+ public Optional<Transfer> get(Long id)
{
return
Optional
});
}
- @Override
- public synchronized void update(Long id, Transfer.State oldState, Transfer.State newState)
- {
- Transfer transfer = get(id).orElseThrow(() -> new IllegalArgumentException("Could not find transfer " + id));
-
- if (transfer.getState() != oldState)
- throw new IllegalArgumentException(("Unexpectd state for " + transfer + ", expected: " + oldState));
-
- transfer.setState(newState);
- put(transfer);
- }
-
@Override
public void remove(Long id)
{