IGNITE-891 - Cache store improvements
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/79258ba1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/79258ba1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/79258ba1 Branch: refs/heads/ignite-891 Commit: 79258ba1e5b6e009ffe3d8bc504f81955ffb5c21 Parents: 0c52898 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Fri May 15 16:08:59 2015 -0700 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Fri May 15 16:08:59 2015 -0700 ---------------------------------------------------------------------- .../ignite/cache/store/CacheStoreSessionListener.java | 13 ++++++++++++- .../store/jdbc/CacheStoreSessionJdbcListener.java | 2 +- .../hibernate/CacheStoreSessionHibernateListener.java | 2 +- .../store/spring/CacheStoreSessionSpringListener.java | 2 +- 4 files changed, 15 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/79258ba1/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java index e57714b..cba66c3 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/CacheStoreSessionListener.java @@ -18,10 +18,21 @@ package org.apache.ignite.cache.store; /** - * TODO + * Store session listener. */ public interface CacheStoreSessionListener { + /** + * On session start callback. + * + * @param ses Current session. + */ public void onSessionStart(CacheStoreSession ses); + /** + * On session end callback. + * + * @param ses Current session. + * @param commit {@code True} if transaction should commit, {@code false} for rollback. + */ public void onSessionEnd(CacheStoreSession ses, boolean commit); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/79258ba1/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheStoreSessionJdbcListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheStoreSessionJdbcListener.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheStoreSessionJdbcListener.java index 9622063..87ed5c1 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheStoreSessionJdbcListener.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheStoreSessionJdbcListener.java @@ -27,7 +27,7 @@ import java.sql.*; import java.util.*; /** - * TODO + * Cache store session listener based on JDBC connection. */ public class CacheStoreSessionJdbcListener implements CacheStoreSessionListener { /** Session key for JDBC connection. */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/79258ba1/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheStoreSessionHibernateListener.java ---------------------------------------------------------------------- diff --git a/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheStoreSessionHibernateListener.java b/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheStoreSessionHibernateListener.java index eff5e6c..e1fd4b2 100644 --- a/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheStoreSessionHibernateListener.java +++ b/modules/hibernate/src/main/java/org/apache/ignite/cache/store/hibernate/CacheStoreSessionHibernateListener.java @@ -26,7 +26,7 @@ import javax.cache.integration.*; import java.util.*; /** - * TODO + * Cache store session listener based on Hibernate session. */ public class CacheStoreSessionHibernateListener implements CacheStoreSessionListener { /** Session key for JDBC connection. */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/79258ba1/modules/spring/src/main/java/org/apache/ignite/cache/store/spring/CacheStoreSessionSpringListener.java ---------------------------------------------------------------------- diff --git a/modules/spring/src/main/java/org/apache/ignite/cache/store/spring/CacheStoreSessionSpringListener.java b/modules/spring/src/main/java/org/apache/ignite/cache/store/spring/CacheStoreSessionSpringListener.java index a2cf622..e0caad5 100644 --- a/modules/spring/src/main/java/org/apache/ignite/cache/store/spring/CacheStoreSessionSpringListener.java +++ b/modules/spring/src/main/java/org/apache/ignite/cache/store/spring/CacheStoreSessionSpringListener.java @@ -26,7 +26,7 @@ import org.springframework.transaction.support.*; import javax.cache.integration.*; /** - * TODO + * Cache store session listener based on Spring cache manager. */ public class CacheStoreSessionSpringListener implements CacheStoreSessionListener { /** Session key for transaction status. */
