io.openmessaging.joyqueue

类 MessagingAccessPointImpl

java.lang.Object

io.openmessaging.joyqueue.MessagingAccessPointImpl

所有已实现的接口:

io.openmessaging.MessagingAccessPoint

public class MessagingAccessPointImpl
extends Object
implements io.openmessaging.MessagingAccessPoint

MessagingAccessPointImpl author: gaohaoxiang date: 2019/2/18

字段概要

字段

限定符和类型	字段和说明
protected org.slf4j.Logger	logger

构造器概要

构造器

构造器和说明
MessagingAccessPointImpl(io.openmessaging.KeyValue attributes)

方法概要

限定符和类型	方法和说明
io.openmessaging.KeyValue	attributes()
io.openmessaging.consumer.Consumer	createConsumer()
protected ExtensionMessageFactory	createMessageFactory()
io.openmessaging.producer.Producer	createProducer()
io.openmessaging.producer.Producer	createProducer(io.openmessaging.producer.TransactionStateCheckListener transactionStateCheckListener)
protected MessageAccessPointHolder	getOrCreateMessageAccessPointHolder()
io.openmessaging.message.MessageFactory	messageFactory()
io.openmessaging.manager.ResourceManager	resourceManager()
String	version()

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

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

字段详细资料

logger

protected final org.slf4j.Logger logger

构造器详细资料

MessagingAccessPointImpl

public MessagingAccessPointImpl(io.openmessaging.KeyValue attributes)

方法详细资料

createMessageFactory

protected ExtensionMessageFactory createMessageFactory()

createProducer

public io.openmessaging.producer.Producer createProducer()

指定者:

createProducer 在接口中 io.openmessaging.MessagingAccessPoint

createProducer

public io.openmessaging.producer.Producer createProducer(io.openmessaging.producer.TransactionStateCheckListener transactionStateCheckListener)

指定者:

createProducer 在接口中 io.openmessaging.MessagingAccessPoint

createConsumer

public io.openmessaging.consumer.Consumer createConsumer()

指定者:

createConsumer 在接口中 io.openmessaging.MessagingAccessPoint

getOrCreateMessageAccessPointHolder

protected MessageAccessPointHolder getOrCreateMessageAccessPointHolder()

resourceManager

public io.openmessaging.manager.ResourceManager resourceManager()

指定者:

resourceManager 在接口中 io.openmessaging.MessagingAccessPoint

messageFactory

public io.openmessaging.message.MessageFactory messageFactory()

指定者:

messageFactory 在接口中 io.openmessaging.MessagingAccessPoint

attributes

public io.openmessaging.KeyValue attributes()

指定者:

attributes 在接口中 io.openmessaging.MessagingAccessPoint

version

public String version()

指定者:

version 在接口中 io.openmessaging.MessagingAccessPoint