public void sessionEnd()

in lagerta-core/src/main/java/com/epam/lagerta/capturer/DataCapturerBus.java [214:232]

• 19 lines of code
• 7 McCabe index (conditional complexity)

    public void sessionEnd(boolean commit) throws CacheWriterException {
        Transaction transaction = session.transaction();
        if (transaction == null) {
            return;
        }
        Map<Object, Object> properties = session.properties();
        if (!commit) {
            Map bigBuffer = (Map) properties.get(BUFFER_PROPERTY_NAME);
            if (bigBuffer != null) {
                bigBuffer.remove(cacheName);
            }
        }
        Set<String> caches = (Set<String>) properties.get(CACHES_PROPERTY_NAME);
        if (caches != null && caches.remove(cacheName) && caches.isEmpty()) {
            Map<String, Collection<Cache.Entry<?, ?>>> buffer =
                    (Map<String, Collection<Cache.Entry<?, ?>>>) properties.get(BUFFER_PROPERTY_NAME);
            notifyListeners(nextTransactionId(), buffer);
        }
    }