Interface OffloadTask.Body

Enclosing class:
OffloadTask
public static interface OffloadTask.Body
Callback с телом выполнения offload-задачи.

Callback containing the body of an offload task.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    execute(int messageTypeId, long correlationId, org.agrona.concurrent.UnsafeBuffer payloadCopy, int payloadLength, Object handlerEntry, Object executionState)
    Выполняет обработку одного входящего запроса.

  • Method Details

    • execute

      void execute(int messageTypeId, long correlationId, org.agrona.concurrent.UnsafeBuffer payloadCopy, int payloadLength, Object handlerEntry, Object executionState)
      Выполняет обработку одного входящего запроса.

      Executes processing of one incoming request.

      Parameters:
      messageTypeId - идентификатор типа сообщения / message type identifier
      correlationId - идентификатор корреляции запроса / request correlation identifier
      payloadCopy - копия payload для offload-потока / payload copy for the offload thread
      payloadLength - длина payload в байтах / payload length in bytes
      handlerEntry - запись зарегистрированного обработчика / registered handler entry
      executionState - reusable execution state for the task