Package io.kroxylicious.proxy.internal

Class InternalResponseFrame<B extends org.apache.kafka.common.protocol.ApiMessage>

java.lang.Object

io.netty.util.AbstractReferenceCounted

io.kroxylicious.proxy.frame.DecodedFrame<org.apache.kafka.common.message.ResponseHeaderData,B>

io.kroxylicious.proxy.frame.DecodedResponseFrame<B>

io.kroxylicious.proxy.internal.InternalResponseFrame<B>

All Implemented Interfaces:

Frame, ResponseFrame, io.netty.util.ReferenceCounted

public class InternalResponseFrame<B extends org.apache.kafka.common.protocol.ApiMessage>
extends DecodedResponseFrame<B>

Field Summary

Fields inherited from class io.kroxylicious.proxy.frame.DecodedFrame

apiVersion, body, correlationId, header

Fields inherited from interface io.kroxylicious.proxy.frame.Frame

FRAME_SIZE_LENGTH

Constructor Summary

Constructors

Constructor	Description
InternalResponseFrame(io.kroxylicious.proxy.filter.Filter recipient, short apiVersion, int correlationId, org.apache.kafka.common.message.ResponseHeaderData header, B body, CompletableFuture<?> future)

Method Summary

Modifier and Type	Method	Description
boolean	isRecipient(io.kroxylicious.proxy.filter.Filter candidate)
CompletableFuture<?>	promise()
io.kroxylicious.proxy.filter.Filter	recipient()
String	toString()

Methods inherited from class io.kroxylicious.proxy.frame.DecodedResponseFrame

headerVersion

Methods inherited from class io.kroxylicious.proxy.frame.DecodedFrame

add, apiKey, apiKeyId, apiVersion, body, correlationId, deallocate, encode, estimateEncodedSize, header, isDecoded, touch, transferBuffersTo

Methods inherited from class io.netty.util.AbstractReferenceCounted

refCnt, release, release, retain, retain, setRefCnt, touch

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.kroxylicious.proxy.frame.Frame

apiKeyId, apiVersion, correlationId, encode, estimateEncodedSize, isDecoded

Constructor Details

InternalResponseFrame

public InternalResponseFrame(io.kroxylicious.proxy.filter.Filter recipient,
 short apiVersion,
 int correlationId,
 org.apache.kafka.common.message.ResponseHeaderData header,
 B body,
 CompletableFuture<?> future)

Method Details

isRecipient

public boolean isRecipient(io.kroxylicious.proxy.filter.Filter candidate)

recipient

public io.kroxylicious.proxy.filter.Filter recipient()

promise

public CompletableFuture<?> promise()

toString

public String toString()

Overrides:

toString in class DecodedFrame<org.apache.kafka.common.message.ResponseHeaderData,B extends org.apache.kafka.common.protocol.ApiMessage>