aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/at/gv/egiz/moazs/repository/InMemoryDeliveryRepository.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/at/gv/egiz/moazs/repository/InMemoryDeliveryRepository.java')
-rw-r--r--src/main/java/at/gv/egiz/moazs/repository/InMemoryDeliveryRepository.java13
1 files changed, 7 insertions, 6 deletions
diff --git a/src/main/java/at/gv/egiz/moazs/repository/InMemoryDeliveryRepository.java b/src/main/java/at/gv/egiz/moazs/repository/InMemoryDeliveryRepository.java
index b8a6d78..23c534c 100644
--- a/src/main/java/at/gv/egiz/moazs/repository/InMemoryDeliveryRepository.java
+++ b/src/main/java/at/gv/egiz/moazs/repository/InMemoryDeliveryRepository.java
@@ -32,41 +32,42 @@ public class InMemoryDeliveryRepository implements DeliveryRepository {
this.binaryResponseRepository = builder.build();
}
+ //TODO: Handle all "key exists" cases!
@Override
public void store(DeliveryRequestType request) {
var key = request.getMetaData().getAppDeliveryID();
- log.trace("Store DeliveryRequest by key={}", key);
+ log.info("Store DeliveryRequest by key={}.", key);
requestRepository.put(key, request);
}
@Override
public Optional<DeliveryRequestType> retrieveDeliveryRequest(String appDeliveryID) {
- log.trace("Retrieve DeliveryRequest by key={}", appDeliveryID);
+ log.info("Retrieve DeliveryRequest by key={}.", appDeliveryID);
return ofNullable(requestRepository.getIfPresent(appDeliveryID));
}
@Override
public void store(MsgResponse response) {
String key = response.getResponseID();
- log.trace("Store MsgResponse by key={}", key);
+ log.info("Store MsgResponse by key={}.", key);
responseRepository.put(key, response);
}
@Override
public Optional<MsgResponse> retrieveResponse(String responseID) {
- log.trace("Retrieve MsgResponse by key={}", responseID);
+ log.info("Retrieve MsgResponse by key={}.", responseID);
return ofNullable(responseRepository.getIfPresent(responseID));
}
@Override
public void store(String responseID, byte[] data) {
- log.trace("Store Binary MsgResponse by key={}", responseID);
+ log.info("Store Binary MsgResponse by key={}.", responseID);
binaryResponseRepository.put(responseID, data);
}
@Override
public Optional<byte[]> retrieveBinaryResponse(String responseID) {
- log.trace("Retrieve Binary MsgResponse by key={}", responseID);
+ log.info("Retrieve Binary MsgResponse by key={}.", responseID);
return ofNullable(binaryResponseRepository.getIfPresent(responseID));
}