io.openmessaging.joyqueue.support

类 ProducerWrapper

java.lang.Object

io.openmessaging.joyqueue.support.ProducerWrapper

所有已实现的接口:

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

public class ProducerWrapper
extends Object
implements ExtensionProducer

ProducerWrapper author: gaohaoxiang date: 2019/5/14

构造器概要

构造器

构造器和说明
ProducerWrapper(ExtensionProducer delegate, MessageAccessPointHolder messageAccessPointHolder)

方法概要

限定符和类型	方法和说明
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()
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

构造器详细资料

ProducerWrapper

public ProducerWrapper(ExtensionProducer delegate,
                       MessageAccessPointHolder messageAccessPointHolder)

方法详细资料

prepare

public ExtensionTransactionalResult prepare()

指定者:

prepare 在接口中 ExtensionProducer

prepare

public ExtensionTransactionalResult prepare(String transactionId)

指定者:

prepare 在接口中 ExtensionProducer

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

getExtension

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

指定者:

getExtension 在接口中 io.openmessaging.Client

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

getQueueMetaData

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

指定者:

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

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