diff --git a/lib/twitter4j4r/client.rb b/lib/twitter4j4r/client.rb
index <HASH>..<HASH> 100644
--- a/lib/twitter4j4r/client.rb
+++ b/lib/twitter4j4r/client.rb
@@ -1,5 +1,3 @@
-require 'jruby/core_ext'
-
 require 'jar/twitter4j-core-2.2.6.jar'
 require 'jar/twitter4j-stream-2.2.6.jar'
 require 'jar/twitter4j-async-2.2.6.jar'
@@ -33,7 +31,6 @@ module Twitter4j4r
     end
     
     def start(search_terms)
-      Listener.become_java!
       @stream.addListener(Listener.new(self, @status_block, @exception_block, @limitation_block))
       @stream.filter(Java::Twitter4j::FilterQuery.new(0, nil, search_terms.to_java(:string)))
     end
diff --git a/lib/twitter4j4r/listener.rb b/lib/twitter4j4r/listener.rb
index <HASH>..<HASH> 100644
--- a/lib/twitter4j4r/listener.rb
+++ b/lib/twitter4j4r/listener.rb
@@ -1,4 +1,5 @@
 require 'jar/twitter4j-stream-2.2.6.jar'
+require 'jruby/core_ext'
 
 module Twitter4j4r
     class Listener
@@ -29,3 +30,5 @@ module Twitter4j4r
     end
   end
 end
+
+Twitter4j4r::Listener.become_java!
Move the become_java! call to listener.rb