CommandStoreUtil¶

httpWaitForCommandSequenceNumber¶

void httpWaitForCommandSequenceNumber(
  CommandQueue commandQueue,
  KsqlRequest request,
  Duration timeout)

httpWaitForCommandSequenceNumber...FIXME

httpWaitForCommandSequenceNumber is used when:

• KsqlResource is requested to handleKsqlStatements
• StreamedQueryResource is requested to streamQuery.

waitForCommandSequenceNumber¶

void waitForCommandSequenceNumber(
  CommandQueue commandQueue,
  KsqlRequest request,
  Duration timeout)

waitForCommandSequenceNumber requests the given KsqlRequest for getCommandSequenceNumber and, only if the sequence number is specified, requests the given CommandQueue to ensureConsumedPast.

waitForCommandSequenceNumber is used when:

• WSQueryEndpoint is requested to executeStreamQuery
• CommandStoreUtil is requested to httpWaitForCommandSequenceNumber.