Repository: usergrid Updated Branches: refs/heads/master 432a8f85e -> 746416736
Call clearQueueNameCache during test database schema destruction. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/74641673 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/74641673 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/74641673 Branch: refs/heads/master Commit: 74641673693d8ebc62b89d66339aea77cfe2755d Parents: 432a8f8 Author: Michael Russo <[email protected]> Authored: Sat Nov 19 00:02:04 2016 -0800 Committer: Michael Russo <[email protected]> Committed: Sat Nov 19 00:02:04 2016 -0800 ---------------------------------------------------------------------- .../java/org/apache/usergrid/persistence/CoreSchemaManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/74641673/stack/core/src/test/java/org/apache/usergrid/persistence/CoreSchemaManager.java ---------------------------------------------------------------------- diff --git a/stack/core/src/test/java/org/apache/usergrid/persistence/CoreSchemaManager.java b/stack/core/src/test/java/org/apache/usergrid/persistence/CoreSchemaManager.java index d5687cf..34c29ac 100644 --- a/stack/core/src/test/java/org/apache/usergrid/persistence/CoreSchemaManager.java +++ b/stack/core/src/test/java/org/apache/usergrid/persistence/CoreSchemaManager.java @@ -18,6 +18,7 @@ package org.apache.usergrid.persistence; import org.apache.usergrid.locking.LockManager; +import org.apache.usergrid.persistence.queue.LegacyQueueManager; import org.apache.usergrid.persistence.queue.impl.QakkaQueueManager; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -90,7 +91,8 @@ public class CoreSchemaManager implements SchemaManager { //swallow if it just doesn't exist } logger.info( "keyspaces dropped" ); - SpringResource.getInstance().getBean( Injector.class ).getInstance( QakkaQueueManager.class ); + SpringResource.getInstance().getBean( Injector.class ) + .getInstance( LegacyQueueManager.class ).clearQueueNameCache(); logger.info( "dropping indices" ); final EsProvider provider = SpringResource.getInstance().getBean( Injector.class ).getInstance( EsProvider.class );
