public class BrokerRepository extends Object
| 构造器和说明 |
|---|
BrokerRepository(BaseRepository baseRepository) |
| 限定符和类型 | 方法和说明 |
|---|---|
BrokerDTO |
add(BrokerDTO brokerDTO) |
int |
deleteById(long id) |
List<BrokerDTO> |
getAll() |
BrokerDTO |
getById(long id) |
List<BrokerDTO> |
getByIds(List ids) |
BrokerDTO |
getByIpAndPort(String ip,
int port) |
List<BrokerDTO> |
getByRetryType(String retryType) |
int |
getSearchCount(BrokerQuery query) |
protected String |
getSearchSql(String prefix,
BrokerQuery query,
List<Object> params) |
List<BrokerDTO> |
search(org.joyqueue.model.QPageQuery<BrokerQuery> pageQuery) |
BrokerDTO |
update(BrokerDTO brokerDTO) |
public BrokerRepository(BaseRepository baseRepository)
public BrokerDTO getById(long id)
public int getSearchCount(BrokerQuery query)
public List<BrokerDTO> search(org.joyqueue.model.QPageQuery<BrokerQuery> pageQuery)
protected String getSearchSql(String prefix, BrokerQuery query, List<Object> params)
public int deleteById(long id)
Copyright © 2020 Joyqueue Community. All rights reserved.