Repository: activemq Updated Branches: refs/heads/master 00d19e7b6 -> 130455c92
https://issues.apache.org/jira/browse/AMQ-5968 Fixing a potential null pointer exception when attempting to use scheduler support with replicated levelDB, which is currently not supported. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/130455c9 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/130455c9 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/130455c9 Branch: refs/heads/master Commit: 130455c925786c4bf3333e59240ff0789b9d026f Parents: 00d19e7 Author: Christopher L. Shannon (cshannon) <[email protected]> Authored: Mon Sep 21 17:37:02 2015 +0000 Committer: Christopher L. Shannon (cshannon) <[email protected]> Committed: Mon Sep 21 17:37:02 2015 +0000 ---------------------------------------------------------------------- .../org/apache/activemq/leveldb/replicated/ProxyLevelDBStore.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/130455c9/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ProxyLevelDBStore.scala ---------------------------------------------------------------------- diff --git a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ProxyLevelDBStore.scala b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ProxyLevelDBStore.scala index efd55f3..7b62a95 100644 --- a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ProxyLevelDBStore.scala +++ b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ProxyLevelDBStore.scala @@ -46,7 +46,7 @@ abstract class ProxyLevelDBStore extends LockableServiceSupport with BrokerServi } def createJobSchedulerStore():JobSchedulerStore = { - return proxy_target.createJobSchedulerStore() + throw new UnsupportedOperationException(); } def setDirectory(dir: File) {
