io.openmessaging.joyqueue.producer.support

类 ProducerImpl

java.lang.Object

org.joyqueue.toolkit.service.Activity

org.joyqueue.toolkit.service.Service

io.openmessaging.joyqueue.support.AbstractServiceLifecycle

io.openmessaging.joyqueue.producer.support.ProducerImpl

所有已实现的接口:

io.openmessaging.Client, io.openmessaging.extension.Extension, ExtensionMessageFactory, ExtensionProducer, io.openmessaging.message.MessageFactory, io.openmessaging.producer.Producer, io.openmessaging.ServiceLifecycle, LifeCycle, Online

public class ProducerImpl
extends AbstractServiceLifecycle
implements ExtensionProducer

ProducerImpl author: gaohaoxiang date: 2019/2/19

嵌套类概要

从类继承的嵌套类/接口 org.joyqueue.toolkit.service.Service

Service.Election, Service.ElectionListener

从类继承的嵌套类/接口 org.joyqueue.toolkit.service.Activity

Activity.ServiceState

字段概要

从类继承的字段 org.joyqueue.toolkit.service.Activity

readLock, rwLock, serviceState, signal, started, writeLock

构造器概要

构造器

构造器和说明
ProducerImpl(MessageProducer messageProducer, ExtensionMessageFactory messageFactory)

方法概要

限定符和类型	方法和说明
void	addInterceptor(io.openmessaging.interceptor.ProducerInterceptor interceptor)
protected List<ProduceMessage>	checkAndConvertMessage(List<io.openmessaging.message.Message> messages)
io.openmessaging.message.Message	createMessage(String queueName, byte[] body)
io.openmessaging.message.Message	createMessage(String queueName, String body)
protected void	doStart()
protected void	doStop()
Optional<io.openmessaging.extension.Extension>	getExtension()
io.openmessaging.extension.QueueMetaData	getQueueMetaData(String queueName)
protected io.openmessaging.exception.OMSRuntimeException	handleProduceException(Throwable cause)
ExtensionTransactionalResult	prepare()
io.openmessaging.producer.TransactionalResult	prepare(io.openmessaging.message.Message message)
ExtensionTransactionalResult	prepare(String transactionId)
void	removeInterceptor(io.openmessaging.interceptor.ProducerInterceptor interceptor)
void	send(List<io.openmessaging.message.Message> messages)
io.openmessaging.producer.SendResult	send(io.openmessaging.message.Message message)
io.openmessaging.Future<io.openmessaging.producer.SendResult>	sendAsync(List<io.openmessaging.message.Message> messages)
io.openmessaging.Future<io.openmessaging.producer.SendResult>	sendAsync(io.openmessaging.message.Message message)
void	sendOneway(List<io.openmessaging.message.Message> messages)
void	sendOneway(io.openmessaging.message.Message message)

从类继承的方法 io.openmessaging.joyqueue.support.AbstractServiceLifecycle

currentState, start, stop

从类继承的方法 org.joyqueue.toolkit.service.Service

getServiceState, isReady, isStarted, isStopped, stop, validate, willStop

从类继承的方法 org.joyqueue.toolkit.service.Activity

afterStart, afterStop, await, beforeStart, beforeStop, convert, getReadLock, getWriteLock, startError

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

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

从接口继承的方法 io.openmessaging.ServiceLifecycle

currentState, start, stop

构造器详细资料

ProducerImpl

public ProducerImpl(MessageProducer messageProducer,
                    ExtensionMessageFactory messageFactory)

方法详细资料

doStart

protected void doStart()
                throws Exception

覆盖:

doStart 在类中 Activity

抛出:

Exception

doStop

protected void doStop()

覆盖:

doStop 在类中 Activity

send

public io.openmessaging.producer.SendResult send(io.openmessaging.message.Message message)

指定者:

send 在接口中 io.openmessaging.producer.Producer

sendAsync

public io.openmessaging.Future<io.openmessaging.producer.SendResult> sendAsync(io.openmessaging.message.Message message)

指定者:

sendAsync 在接口中 io.openmessaging.producer.Producer

sendOneway

public void sendOneway(io.openmessaging.message.Message message)

指定者:

sendOneway 在接口中 io.openmessaging.producer.Producer

send

public void send(List<io.openmessaging.message.Message> messages)

指定者:

send 在接口中 io.openmessaging.producer.Producer

sendAsync

public io.openmessaging.Future<io.openmessaging.producer.SendResult> sendAsync(List<io.openmessaging.message.Message> messages)

指定者:

sendAsync 在接口中 io.openmessaging.producer.Producer

sendOneway

public void sendOneway(List<io.openmessaging.message.Message> messages)

指定者:

sendOneway 在接口中 io.openmessaging.producer.Producer

addInterceptor

public void addInterceptor(io.openmessaging.interceptor.ProducerInterceptor interceptor)

指定者:

addInterceptor 在接口中 io.openmessaging.producer.Producer

removeInterceptor

public void removeInterceptor(io.openmessaging.interceptor.ProducerInterceptor interceptor)

指定者:

removeInterceptor 在接口中 io.openmessaging.producer.Producer

prepare

public io.openmessaging.producer.TransactionalResult prepare(io.openmessaging.message.Message message)

指定者:

prepare 在接口中 io.openmessaging.producer.Producer

prepare

public ExtensionTransactionalResult prepare()

指定者:

prepare 在接口中 ExtensionProducer

prepare

public ExtensionTransactionalResult prepare(String transactionId)

指定者:

prepare 在接口中 ExtensionProducer

createMessage

public io.openmessaging.message.Message createMessage(String queueName,
                                                      byte[] body)

指定者:

createMessage 在接口中 io.openmessaging.message.MessageFactory

createMessage

public io.openmessaging.message.Message createMessage(String queueName,
                                                      String body)

指定者:

createMessage 在接口中 ExtensionMessageFactory

getExtension

public Optional<io.openmessaging.extension.Extension> getExtension()

指定者:

getExtension 在接口中 io.openmessaging.Client

getQueueMetaData

public io.openmessaging.extension.QueueMetaData getQueueMetaData(String queueName)

指定者:

getQueueMetaData 在接口中 io.openmessaging.extension.Extension

checkAndConvertMessage

protected List<ProduceMessage> checkAndConvertMessage(List<io.openmessaging.message.Message> messages)

handleProduceException

protected io.openmessaging.exception.OMSRuntimeException handleProduceException(Throwable cause)