io.openmessaging.joyqueue.producer.support

类 TransactionProducerImpl

java.lang.Object

io.openmessaging.joyqueue.producer.support.TransactionProducerImpl

所有已实现的接口:

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

public class TransactionProducerImpl
extends Object
implements ExtensionProducer

TransactionProducerImpl author: gaohaoxiang date: 2019/2/22

构造器概要

构造器

构造器和说明
TransactionProducerImpl(ExtensionProducer delegate, io.openmessaging.producer.TransactionStateCheckListener transactionStateCheckListener, MessageProducer messageProducer, MessageAccessPoint messageAccessPoint, TxFeedbackConfig txFeedbackConfig)

方法概要

限定符和类型	方法和说明
void	addInterceptor(io.openmessaging.interceptor.ProducerInterceptor interceptor)
io.openmessaging.message.Message	createMessage(String queueName, byte[] body)
io.openmessaging.message.Message	createMessage(String queueName, String body)
io.openmessaging.ServiceLifeState	currentState()
protected void	doProcessCreateMessage(String queueName)
Optional<io.openmessaging.extension.Extension>	getExtension()
io.openmessaging.extension.QueueMetaData	getQueueMetaData(String queueName)
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)
void	start()
void	stop()

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

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

构造器详细资料

TransactionProducerImpl

public TransactionProducerImpl(ExtensionProducer delegate,
                               io.openmessaging.producer.TransactionStateCheckListener transactionStateCheckListener,
                               MessageProducer messageProducer,
                               MessageAccessPoint messageAccessPoint,
                               TxFeedbackConfig txFeedbackConfig)

方法详细资料

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(String transactionId)

指定者:

prepare 在接口中 ExtensionProducer

prepare

public ExtensionTransactionalResult prepare()

指定者:

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

doProcessCreateMessage

protected void doProcessCreateMessage(String queueName)

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

start

public void start()

指定者:

start 在接口中 io.openmessaging.ServiceLifecycle

stop

public void stop()

指定者:

stop 在接口中 io.openmessaging.ServiceLifecycle

currentState

public io.openmessaging.ServiceLifeState currentState()

指定者:

currentState 在接口中 io.openmessaging.ServiceLifecycle