# sprint-2 - exception fix.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/6097e7bf Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/6097e7bf Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/6097e7bf Branch: refs/heads/ignite-344 Commit: 6097e7bfc3af49296b50017d5661d313aaa3db80 Parents: a14ef18 Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Sat Feb 28 00:29:42 2015 -0500 Committer: Dmitiry Setrakyan <dsetrak...@gridgain.com> Committed: Sat Feb 28 00:29:42 2015 -0500 ---------------------------------------------------------------------- .../examples/datagrid/store/jdbc/CacheJdbcPersonStore.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6097e7bf/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java index 6388fbf..d80861d 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java @@ -92,7 +92,7 @@ public class CacheJdbcPersonStore extends CacheStoreAdapter<Long, Person> { } /** {@inheritDoc} */ - @Nullable @Override public Person load(Long key) { + @Override public Person load(Long key) { Transaction tx = transaction(); System.out.println(">>> Store load [key=" + key + ", xid=" + (tx == null ? null : tx.xid()) + ']'); @@ -185,7 +185,7 @@ public class CacheJdbcPersonStore extends CacheStoreAdapter<Long, Person> { } } catch (SQLException e) { - throw new CacheLoaderException("Failed to remove object: " + key, e); + throw new CacheWriterException("Failed to remove object: " + key, e); } finally { end(tx, conn); @@ -302,7 +302,7 @@ public class CacheJdbcPersonStore extends CacheStoreAdapter<Long, Person> { /** * @return Current transaction. */ - @Nullable private Transaction transaction() { + private Transaction transaction() { return ses != null ? ses.transaction() : null; } }
