Package io.smallrye.reactive.messaging.kafka.reply

Class KafkaRequestReplyImpl.PendingReplyImpl<Rep>

java.lang.Object

io.smallrye.reactive.messaging.kafka.reply.KafkaRequestReplyImpl.PendingReplyImpl<Rep>

All Implemented Interfaces:

PendingReply

Enclosing class:

KafkaRequestReplyImpl<Req,Rep>

public static class KafkaRequestReplyImpl.PendingReplyImpl<Rep>
extends Object
implements PendingReply

Constructor Summary

Constructors

Constructor	Description
PendingReplyImpl(org.apache.kafka.clients.producer.RecordMetadata metadata, String replyTopic, int replyPartition, io.smallrye.mutiny.subscription.MultiEmitter<org.eclipse.microprofile.reactive.messaging.Message<Rep>> emitter)

Method Summary

Modifier and Type	Method	Description
void	complete()	Complete the pending reply.
io.smallrye.mutiny.subscription.MultiEmitter<org.eclipse.microprofile.reactive.messaging.Message<Rep>>	getEmitter()
boolean	isCancelled()
org.apache.kafka.clients.producer.RecordMetadata	recordMetadata()
int	replyPartition()
String	replyTopic()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

PendingReplyImpl

public PendingReplyImpl(org.apache.kafka.clients.producer.RecordMetadata metadata,
 String replyTopic,
 int replyPartition,
 io.smallrye.mutiny.subscription.MultiEmitter<org.eclipse.microprofile.reactive.messaging.Message<Rep>> emitter)

Method Details

replyTopic

public String replyTopic()

Specified by:

replyTopic in interface PendingReply

Returns:

reply topic

replyPartition

public int replyPartition()

Specified by:

replyPartition in interface PendingReply

Returns:

reply partition, -1 if not set

recordMetadata

public org.apache.kafka.clients.producer.RecordMetadata recordMetadata()

Specified by:

recordMetadata in interface PendingReply

Returns:

the recordMetadata of the request

complete

public void complete()

Description copied from interface: PendingReply

Complete the pending reply.

Specified by:

complete in interface PendingReply

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface PendingReply

Returns:

whether the pending reply was terminated (with a completion or failure).

getEmitter

public io.smallrye.mutiny.subscription.MultiEmitter<org.eclipse.microprofile.reactive.messaging.Message<Rep>> getEmitter()

toString

public String toString()

Overrides:

toString in class Object