public TagConsumer(GitHubEndpoint endpoint, Processor processor) throws Exception {
        super(endpoint, processor);

        LOG.info("GitHub TagConsumer: Indexing current tags...");
        List<RepositoryTag> tags = getRepositoryService().getTags(getRepository());
        for (RepositoryTag tag : tags) {
            tagNames.add(tag.getName());
        }
    }
@Test
    public void tagConsumerTest() throws Exception {
        RepositoryTag tag1 = repositoryService.addTag("TAG1");
        RepositoryTag tag2 = repositoryService.addTag("TAG2");
        RepositoryTag tag3 = repositoryService.addTag("TAG3");
        mockResultEndpoint.expectedBodiesReceivedInAnyOrder(tag1, tag2, tag3);
        Thread.sleep(1 * 1000);

        mockResultEndpoint.assertIsSatisfied();
    }