public TopicList getAllTopicList() {
        TopicList topicList = new TopicList();
        try {
            this.lock.readLock().lockInterruptibly();
            topicList.getTopicList().addAll(this.topicQueueTable.keySet());
        } catch (Exception e) {
            log.error("getAllTopicList Exception", e);
        } finally {
            this.lock.readLock().unlock();
        }

        return topicList;
    }
@Test
    public void testGetAllTopicList() {
        byte[] topicInfo = routeInfoManager.getAllTopicList().encode();
        Assert.assertTrue(topicInfo != null);
        assertThat(topicInfo).isNotNull();
    }