Siddhi Query от Redis

похоже, у меня проблема с запросом Сиддхи из Redis. Код ниже не выводит OutputStream. У меня есть ключ в имени Redis как fo1

       "@store(type='redis', host='x.x.x.x', port='6379', table.name='RedisTable')" +
        "@PrimaryKey('key')" +
        "define table RedisTable(key string, value string); " +

        "define stream FooStream (name string); " +
        "define stream OutputStream(name string); " +
        "from FooStream  " +
        "[( RedisTable.key == name ) in RedisTable] " +
        "insert into OutputStream; ";

        SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(streams );

        //Adding callback to retrieve output events from stream
        siddhiAppRuntime.addCallback("OutputStream", new StreamCallback() {
            @Override
            public void receive(Event[] events) {
                EventPrinter.print(events);
                //To convert and print event as a map
                //EventPrinter.print(toMap(events));
            }
        });

        InputHandler inputHandler = siddhiAppRuntime.getInputHandler("FooStream");
        inputHandler.send(new Object[]{"fo1"});

Redis:

Я ожидаю вывода fo1 для OutputStream, но почему-то ничего не печатает.