org.joyqueue.nsr.sql.service

类 SQLBrokerInternalService

java.lang.Object

org.joyqueue.nsr.sql.service.SQLBrokerInternalService

所有已实现的接口:

BrokerInternalService

public class SQLBrokerInternalService
extends Object
implements BrokerInternalService

SQLBrokerInternalService author: gaohaoxiang date: 2019/8/16

构造器概要

构造器

构造器和说明
SQLBrokerInternalService(BrokerRepository brokerRepository)

方法概要

限定符和类型	方法和说明
org.joyqueue.domain.Broker	add(org.joyqueue.domain.Broker broker)
void	delete(int id)
List<org.joyqueue.domain.Broker>	getAll()
org.joyqueue.domain.Broker	getById(int id)
List<org.joyqueue.domain.Broker>	getByIds(List<Integer> ids)
org.joyqueue.domain.Broker	getByIpAndPort(String brokerIp, Integer brokerPort)
List<org.joyqueue.domain.Broker>	getByRetryType(String retryType)
org.joyqueue.model.PageResult<org.joyqueue.domain.Broker>	search(org.joyqueue.model.QPageQuery<BrokerQuery> pageQuery)
org.joyqueue.domain.Broker	update(org.joyqueue.domain.Broker broker)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SQLBrokerInternalService

public SQLBrokerInternalService(BrokerRepository brokerRepository)

方法详细资料

getByIpAndPort

public org.joyqueue.domain.Broker getByIpAndPort(String brokerIp,
                                                 Integer brokerPort)

指定者:

getByIpAndPort 在接口中 BrokerInternalService

getByRetryType

public List<org.joyqueue.domain.Broker> getByRetryType(String retryType)

指定者:

getByRetryType 在接口中 BrokerInternalService

getByIds

public List<org.joyqueue.domain.Broker> getByIds(List<Integer> ids)

指定者:

getByIds 在接口中 BrokerInternalService

update

public org.joyqueue.domain.Broker update(org.joyqueue.domain.Broker broker)

指定者:

update 在接口中 BrokerInternalService

getById

public org.joyqueue.domain.Broker getById(int id)

指定者:

getById 在接口中 BrokerInternalService

add

public org.joyqueue.domain.Broker add(org.joyqueue.domain.Broker broker)

指定者:

add 在接口中 BrokerInternalService

delete

public void delete(int id)

指定者:

delete 在接口中 BrokerInternalService

getAll

public List<org.joyqueue.domain.Broker> getAll()

指定者:

getAll 在接口中 BrokerInternalService

search

public org.joyqueue.model.PageResult<org.joyqueue.domain.Broker> search(org.joyqueue.model.QPageQuery<BrokerQuery> pageQuery)

指定者:

search 在接口中 BrokerInternalService