org.joyqueue.client.internal

接口 MessageAccessPoint

所有超级接口:

LifeCycle, Online

所有已知实现类:

DefaultMessageAccessPoint

public interface MessageAccessPoint
extends LifeCycle

MessageAccessPoint author: gaohaoxiang date: 2019/2/19

方法概要

限定符和类型	方法和说明
MessageConsumer	createConsumer()
MessageConsumer	createConsumer(ConsumerConfig config)
MessageConsumer	createConsumer(String group)
MessagePoller	createPoller()
MessagePoller	createPoller(ConsumerConfig config)
MessagePoller	createPoller(String group)
MessageProducer	createProducer()
MessageProducer	createProducer(ProducerConfig config)
void	removeTransactionCallback(String topic)
void	setTransactionCallback(String topic, TxFeedbackCallback callback)
void	setTransactionCallback(String topic, TxFeedbackConfig config, TxFeedbackCallback callback)

从接口继承的方法 org.joyqueue.toolkit.lang.LifeCycle

start, stop

从接口继承的方法 org.joyqueue.toolkit.lang.Online

isStarted

方法详细资料

createPoller

MessagePoller createPoller()

createPoller

MessagePoller createPoller(String group)

createPoller

MessagePoller createPoller(ConsumerConfig config)

createConsumer

MessageConsumer createConsumer()

createConsumer

MessageConsumer createConsumer(String group)

createConsumer

MessageConsumer createConsumer(ConsumerConfig config)

createProducer

MessageProducer createProducer()

createProducer

MessageProducer createProducer(ProducerConfig config)

setTransactionCallback

void setTransactionCallback(String topic,
                            TxFeedbackCallback callback)

setTransactionCallback

void setTransactionCallback(String topic,
                            TxFeedbackConfig config,
                            TxFeedbackCallback callback)

removeTransactionCallback

void removeTransactionCallback(String topic)