如何使用斯波克测试风暴发射大的输出元组时(How to test Storm using Spock

所以，我有如下的测试：

def "test execute(inputTuple) method emits an outputTuple containing a member ObjectType    
retrieved using the entity_id in inputTuple"() {
    given:
    Tuple inputTuple = Mock(Tuple);

    List<String> objectTypeIDsEmittedByPreviousBolt = new ArrayList<String>();
    objectTypeIDsEmittedByPreviousBolt.add("member");
    objectTypeIDsEmittedByPreviousBolt.add("1196");

    1 * inputTuple.getValues() >> objectTypeIDsEmittedByPreviousBolt;

    when:
    this.bolt.execute(inputTuple);

    then:
    1 * this.collector.emit(inputTuple, THE_OUTPUT_TUPLE);
    1 * this.collector.ack(inputTuple);
}

我收到以下错误，我不明白。是inputTuple不匹配或outputTuple不匹配？：

Too few invocations for:

1 * this.collector.emit( inputTuple, [['response':['status':'OK', ... 'member']]]])   (0 invocations)

Unmatched invocations (ordered by similarity):

1 * <OutputCollector>.emit(Mock for type 'Tuple' named 'inputTuple', [['response':['status':'OK', ...'member']]]])


    at org.spockframework.mock.runtime.InteractionScope.verifyInteractions(InteractionScope.java:78)
    at org.spockframework.mock.runtime.MockController.leaveScope(MockController.java:76)
    at member.bolt.CallConsoleAPIToGetAllObjectTypeInfoBoltTest.test execute(inputTuple) method emits an outputTuple containing a member ObjectType retrieved using the entity_id in inputTuple(CallConsoleAPIToGetAllObjectTypeInfoBoltTest.groovy:63)

这是怎么这个测试可能应书面（groovyConsole中工作示例）：

@Grab('org.spockframework:spock-core:0.7-groovy-2.0')
@Grab('cglib:cglib-nodep:3.1')

import spock.lang.*

class Test extends Specification {
    def "test execute(inputTuple) method emits an outputTuple containing a member ObjectType retrieved using the entity_id in inputTuple"() {
        given:    
        List<String> objectTypeIDsEmittedByPreviousBolt = new ArrayList<String>();
        objectTypeIDsEmittedByPreviousBolt.add("member");
        objectTypeIDsEmittedByPreviousBolt.add("1196");

        Tuple inputTuple = new Tuple(objectTypeIDsEmittedByPreviousBolt);

        Bolt bolt = new Bolt()
        Collector collector = GroovyMock(Collector)
        bolt.collector = collector

        when:
        bolt.execute(inputTuple);

        then:
        1 * collector.ack(inputTuple);
    }
}

class Bolt {
    Collector collector = new Collector()
    def execute(o) {
        collector.ack(o)
    }
}

class Collector {
    def ack(o) {
        println o
    }
}