org.joyqueue.nsr.sql.service

类 SQLConsumerInternalService

java.lang.Object

org.joyqueue.nsr.sql.service.SQLConsumerInternalService

所有已实现的接口:

ConsumerInternalService

public class SQLConsumerInternalService
extends Object
implements ConsumerInternalService

SQLConsumerInternalService author: gaohaoxiang date: 2019/8/16

构造器概要

构造器

构造器和说明
SQLConsumerInternalService(ConsumerRepository consumerRepository)

方法概要

限定符和类型	方法和说明
org.joyqueue.domain.Consumer	add(org.joyqueue.domain.Consumer consumer)
void	delete(String id)
List<org.joyqueue.domain.Consumer>	getAll()
List<org.joyqueue.domain.Consumer>	getByApp(String app)
org.joyqueue.domain.Consumer	getById(String id)
List<org.joyqueue.domain.Consumer>	getByTopic(org.joyqueue.domain.TopicName topic)
org.joyqueue.domain.Consumer	getByTopicAndApp(org.joyqueue.domain.TopicName topic, String app)
org.joyqueue.domain.Consumer	update(org.joyqueue.domain.Consumer consumer)

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

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

构造器详细资料

SQLConsumerInternalService

public SQLConsumerInternalService(ConsumerRepository consumerRepository)

方法详细资料

getById

public org.joyqueue.domain.Consumer getById(String id)

指定者:

getById 在接口中 ConsumerInternalService

getByTopicAndApp

public org.joyqueue.domain.Consumer getByTopicAndApp(org.joyqueue.domain.TopicName topic,
                                                     String app)

指定者:

getByTopicAndApp 在接口中 ConsumerInternalService

getByTopic

public List<org.joyqueue.domain.Consumer> getByTopic(org.joyqueue.domain.TopicName topic)

指定者:

getByTopic 在接口中 ConsumerInternalService

getByApp

public List<org.joyqueue.domain.Consumer> getByApp(String app)

指定者:

getByApp 在接口中 ConsumerInternalService

getAll

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

指定者:

getAll 在接口中 ConsumerInternalService

add

public org.joyqueue.domain.Consumer add(org.joyqueue.domain.Consumer consumer)

指定者:

add 在接口中 ConsumerInternalService

update

public org.joyqueue.domain.Consumer update(org.joyqueue.domain.Consumer consumer)

指定者:

update 在接口中 ConsumerInternalService

delete

public void delete(String id)

指定者:

delete 在接口中 ConsumerInternalService