   (:require [backtype.storm.integration-test :as it])
   (:require [backtype.storm.thrift :as thrift])
   (:import [backtype.storm Testing Config ILocalCluster])
-  (:import [backtype.storm.tuple Values TupleImpl])
+  (:import [backtype.storm.tuple Values Tuple])
   (:import [backtype.storm.utils Time Utils])
   (:import [backtype.storm.testing MkClusterParam TestJob MockedSources TestWordSpout
             TestWordCounter TestGlobalCount TestAggregatesCounter CompleteTopologyParam

(deftest test-test-tuple
  (letlocals
   ;; test the one-param signature
   (bind ^TupleImpl tuple (Testing/testTuple ["james" "bond"]))
   (is (= ["james" "bond"] (.getValues tuple)))
   (is (= ["field1" "field2"] (-> tuple .getFields .toList)))
   (is (= "component" (.getSourceComponent tuple)))


     (.setStream "test-stream")
     (.setComponent "test-component")
     (.setFields (into-array String ["fname" "lname"])))
   (bind ^Tuple tuple (Testing/testTuple ["james" "bond"] mk-tuple-param))
   (is (= ["james" "bond"] (.getValues tuple)))
   (is (= "test-stream" (.getSourceStreamId tuple)))
   (is (= ["fname" "lname"] (-> tuple .getFields .toList)))
   (is (= "test-component" (.getSourceComponent tuple)))))
