Add DataMapper::Adapters::CassandraAdapter#reset

* This method will disconnect all clients and then reinitialize the connection pool.
dkubb · Jun 21, 2013 · 77d423f · 77d423f
1 parent 72f1ca6
commit 77d423f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/dm-cassandra-adapter/adapter.rb b/lib/dm-cassandra-adapter/adapter.rb
@@ -49,6 +49,12 @@ def execute(*args)
         nil
       end
 
+      def reset
+        @pool.shutdown(&:disconnect!)
+        @pool = new_pool
+        self
+      end
+
     private
 
       def setup_keyspace