    @Test
    public void test() throws IOException {

        // get dummy scope
        WebScope scope = (WebScope) applicationContext.getBean("web.scope");
        // test file fixture
        File file = new File("target/test-classes/fixtures/test.flv");
        // new file provider instance
        FileProvider provider = new FileProvider(scope, file);
        // data pipe
        IPipe pipe = new InMemoryPullPullPipe();
        // subscribe the provider to the pipe
        pipe.subscribe(provider, null);
        // grab a message from the pipe (can do this until no messages are remaining)
        IMessage msg = pipe.pullMessage();
        log.info("Message: {}", msg);
        assertNotNull(msg);
    }