@Test(expected = RuntimeException.class) public void testFindStorageByTopicTopicNotFound() throws Exception { m_metaService.findStorageByTopic("topicNotFound"); }
@Override public Storage findStorageByTopic(String topicName) { Meta meta = getMeta(); Topic topic = findTopic(topicName, meta); String storageType = topic.getStorageType(); return meta.findStorage(storageType); }
DefaultMetaService implements MetaService, Initializable { @Override public Storage findStorageByTopic(String topicName) { Meta meta = getMeta(); Topic topic = findTopic(topicName, meta); String storageType = topic.getStorageType(); return meta.findStorage(storageType); } }
DefaultMetaService implements MetaService, Initializable { @Override public Storage findStorageByTopic(String topicName) { Meta meta = getMeta(); Topic topic = findTopic(topicName, meta); String storageType = topic.getStorageType(); return meta.findStorage(storageType); }  }
DefaultMetaService implements MetaService, Initializable { @Override public Storage findStorageByTopic(String topicName) { Meta meta = getMeta(); Topic topic = findTopic(topicName, meta); String storageType = topic.getStorageType(); return meta.findStorage(storageType); }  @Override List<Partition> listPartitionsByTopic(String topicName); @Override Storage findStorageByTopic(String topicName); @Override Partition findPartitionByTopicAndPartition(String topicName, int partitionId); @Override List<Topic> listTopicsByPattern(String topicPattern); @Override Topic findTopicByName(String topicName); @Override int translateToIntGroupId(String topicName, String groupName); @Override List<Datasource> listAllMysqlDataSources(); @Override int getAckTimeoutSecondsByTopicAndConsumerGroup(String topicName, String groupId); @Override LeaseAcquireResponse tryAcquireConsumerLease(Tpg tpg, String sessionId); @Override LeaseAcquireResponse tryRenewConsumerLease(Tpg tpg, Lease lease, String sessionId); @Override LeaseAcquireResponse tryRenewBrokerLease(String topic, int partition, Lease lease, String sessionId,
	      int brokerPort); @Override LeaseAcquireResponse tryAcquireBrokerLease(String topic, int partition, String sessionId, int brokerPort); @Override void initialize(); @Override synchronized Pair<Endpoint, Long> findEndpointByTopicAndPartition(String topic, int partition); @Override RetryPolicy findRetryPolicyByTopicAndGroup(String topicName, String groupId); @Override boolean containsEndpoint(Endpoint endpoint); @Override boolean containsConsumerGroup(String topicName, String groupId); @Override Offset findMessageOffsetByTime(String topic, int partition, long time); @Override Map<Integer, Offset> findMessageOffsetByTime(String topic, long time); @Override List<ZookeeperEnsemble> listAllZookeeperEnsemble(); @Override Idc getPrimaryIdc(); }
DefaultMetaService implements MetaService, Initializable { @Override public Storage findStorageByTopic(String topicName) { Meta meta = getMeta(); Topic topic = findTopic(topicName, meta); String storageType = topic.getStorageType(); return meta.findStorage(storageType); }  @Override List<Partition> listPartitionsByTopic(String topicName); @Override Storage findStorageByTopic(String topicName); @Override Partition findPartitionByTopicAndPartition(String topicName, int partitionId); @Override List<Topic> listTopicsByPattern(String topicPattern); @Override Topic findTopicByName(String topicName); @Override int translateToIntGroupId(String topicName, String groupName); @Override List<Datasource> listAllMysqlDataSources(); @Override int getAckTimeoutSecondsByTopicAndConsumerGroup(String topicName, String groupId); @Override LeaseAcquireResponse tryAcquireConsumerLease(Tpg tpg, String sessionId); @Override LeaseAcquireResponse tryRenewConsumerLease(Tpg tpg, Lease lease, String sessionId); @Override LeaseAcquireResponse tryRenewBrokerLease(String topic, int partition, Lease lease, String sessionId,
	      int brokerPort); @Override LeaseAcquireResponse tryAcquireBrokerLease(String topic, int partition, String sessionId, int brokerPort); @Override void initialize(); @Override synchronized Pair<Endpoint, Long> findEndpointByTopicAndPartition(String topic, int partition); @Override RetryPolicy findRetryPolicyByTopicAndGroup(String topicName, String groupId); @Override boolean containsEndpoint(Endpoint endpoint); @Override boolean containsConsumerGroup(String topicName, String groupId); @Override Offset findMessageOffsetByTime(String topic, int partition, long time); @Override Map<Integer, Offset> findMessageOffsetByTime(String topic, long time); @Override List<ZookeeperEnsemble> listAllZookeeperEnsemble(); @Override Idc getPrimaryIdc();  }