@Test public void testList7() { try { this.iProducer.list(0, 101, this.channelName); Assert.fail(); } catch (BrokerException e) { Assert.assertEquals(ErrorCode.TOPIC_PAGE_SIZE_INVALID.getCode(), e.getCode()); } }
@Override public TopicPage list(Integer pageIndex, Integer pageSize, String channelName) throws BrokerException { ParamCheckUtils.validatePagIndexAndSize(pageIndex, pageSize); validateChannelName(channelName); return fabricDelegate.getFabricMap().get(channelName).listTopicName(pageIndex, pageSize); }
FabricTopicAdmin implements IEventTopic { @Override public TopicPage list(Integer pageIndex, Integer pageSize, String channelName) throws BrokerException { ParamCheckUtils.validatePagIndexAndSize(pageIndex, pageSize); validateChannelName(channelName); return fabricDelegate.getFabricMap().get(channelName).listTopicName(pageIndex, pageSize); } }
FabricTopicAdmin implements IEventTopic { @Override public TopicPage list(Integer pageIndex, Integer pageSize, String channelName) throws BrokerException { ParamCheckUtils.validatePagIndexAndSize(pageIndex, pageSize); validateChannelName(channelName); return fabricDelegate.getFabricMap().get(channelName).listTopicName(pageIndex, pageSize); } FabricTopicAdmin(FabricDelegate fabricDelegate); }
FabricTopicAdmin implements IEventTopic { @Override public TopicPage list(Integer pageIndex, Integer pageSize, String channelName) throws BrokerException { ParamCheckUtils.validatePagIndexAndSize(pageIndex, pageSize); validateChannelName(channelName); return fabricDelegate.getFabricMap().get(channelName).listTopicName(pageIndex, pageSize); } FabricTopicAdmin(FabricDelegate fabricDelegate); @Override boolean open(String topic, String channelName); @Override boolean close(String topic, String channelName); @Override WeEvent getEvent(String eventId, String channelName); @Override boolean exist(String topic, String channelName); @Override TopicPage list(Integer pageIndex, Integer pageSize, String channelName); @Override TopicInfo state(String topic, String channelName); @Override List<String> listGroupId(); @Override Long getBlockHeight(String channelName); @Override GroupGeneral getGroupGeneral(String channelName); @Override ListPage<TbTransHash> queryTransList(QueryEntity queryEntity); @Override ListPage<TbBlock> queryBlockList(QueryEntity queryEntity); @Override ListPage<TbNode> queryNodeList(QueryEntity queryEntity); @Override ContractContext getContractContext(String groupId); @Override boolean addOperator(String groupId, String topicName, String address); @Override boolean delOperator(String groupId, String topicName, String address); @Override List<String> listOperator(String groupId, String topicName); @Override void validateGroupId(String channelName); }
FabricTopicAdmin implements IEventTopic { @Override public TopicPage list(Integer pageIndex, Integer pageSize, String channelName) throws BrokerException { ParamCheckUtils.validatePagIndexAndSize(pageIndex, pageSize); validateChannelName(channelName); return fabricDelegate.getFabricMap().get(channelName).listTopicName(pageIndex, pageSize); } FabricTopicAdmin(FabricDelegate fabricDelegate); @Override boolean open(String topic, String channelName); @Override boolean close(String topic, String channelName); @Override WeEvent getEvent(String eventId, String channelName); @Override boolean exist(String topic, String channelName); @Override TopicPage list(Integer pageIndex, Integer pageSize, String channelName); @Override TopicInfo state(String topic, String channelName); @Override List<String> listGroupId(); @Override Long getBlockHeight(String channelName); @Override GroupGeneral getGroupGeneral(String channelName); @Override ListPage<TbTransHash> queryTransList(QueryEntity queryEntity); @Override ListPage<TbBlock> queryBlockList(QueryEntity queryEntity); @Override ListPage<TbNode> queryNodeList(QueryEntity queryEntity); @Override ContractContext getContractContext(String groupId); @Override boolean addOperator(String groupId, String topicName, String address); @Override boolean delOperator(String groupId, String topicName, String address); @Override List<String> listOperator(String groupId, String topicName); @Override void validateGroupId(String channelName);  }