InterBrokerSendThread

InterBrokerSendThread is the extension of the ShutdownableThread contract for inter-broker send threads with a non-blocking NetworkClient that doWork.

Note
 TransactionMarkerChannelManager is the only available implementation of the InterBrokerSendThread Contract in Apache Kafka.

doWork Method

doWork(): Unit
Note
 doWork is a part of ShutdownableThread Contract.

doWork…​FIXME

sendRequests Internal Method

sendRequests(now: Long): Long

sendRequests…​FIXME

Note
 sendRequests is used exclusively when InterBrokerSendThread is requested to doWork.

completeWithDisconnect Method

completeWithDisconnect(
  request: ClientRequest,
  now: Long,
  authenticationException: AuthenticationException): Unit

completeWithDisconnect…​FIXME

Note
 completeWithDisconnect is used when InterBrokerSendThread is requested to checkDisconnects and failExpiredRequests (when InterBrokerSendThread is requested to doWork).

checkDisconnects Internal Method

checkDisconnects(now: Long): Unit

checkDisconnects…​FIXME

Note
 checkDisconnects is used exclusively when InterBrokerSendThread is requested to doWork.

failExpiredRequests Internal Method

failExpiredRequests(now: Long): Unit

failExpiredRequests…​FIXME

Note
 failExpiredRequests is used exclusively when InterBrokerSendThread is requested to doWork.

Creating InterBrokerSendThread Instance

InterBrokerSendThread takes the following to be created:

InterBrokerSendThread initializes the internal registries and counters.

results matching ""

    No results matching ""