diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index 5263afa20..fc0a3aac7 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -914,7 +914,11 @@ class StatelessChronicleMap implements ChronicleMap, Closeable { } private void writeKey(K key) { - keyValueSerializer.writeKey(key, bytes); + try { + keyValueSerializer.writeKey(key, bytes); + } catch (IllegalArgumentException e) { + resizeBuffer(bytes.capacity() + maxEntrySize); + } } private V readKey(final long sizeLocation) { @@ -922,9 +926,11 @@ class StatelessChronicleMap implements ChronicleMap, Closeable { } private void writeValue(V value) { - // LOG.info("bytes position=" + bytes.position() + ",capacity=" + bytes.capacity() + ", " + - // "limit=" + bytes.limit()); - keyValueSerializer.writeValue(value, bytes); + try { + keyValueSerializer.writeValue(value, bytes); + } catch (IllegalArgumentException e) { + resizeBuffer(bytes.capacity() + maxEntrySize); + } } private Set readKeySet(Bytes in) {