package kafka.api
import java.nio.ByteBuffer
import org.apache.kafka.common.requests.AbstractRequestResponse
import kafka.api.ApiUtils._
private[kafka] abstract class GenericRequestAndHeader(val versionId: Short,
val correlationId: Int,
val clientId: String,
val body: AbstractRequestResponse,
val name: String,
override val requestId: Option[Short] = None)
extends RequestOrResponse(requestId) {
def writeTo(buffer: ByteBuffer) {
buffer.putShort(versionId)
buffer.putInt(correlationId)
writeShortString(buffer, clientId)
body.writeTo(buffer)
}
def sizeInBytes(): Int = {
2 +
4 +
(2 + clientId.length) +
body.sizeOf();
}
override def toString(): String = {
describe(true)
}
override def describe(details: Boolean): String = {
val strBuffer = new StringBuilder
strBuffer.append("Name: " + name)
strBuffer.append("; Version: " + versionId)
strBuffer.append("; CorrelationId: " + correlationId)
strBuffer.append("; ClientId: " + clientId)
strBuffer.append("; Body: " + body.toString)
strBuffer.toString()
}
}