Class ManagedExecutionBackend.Session

java.lang.Object
org.j7m.middleware.application.distributed.ManagedExecutionBackend.Session
Enclosing class:
ManagedExecutionBackend
public final class ManagedExecutionBackend.Session extends Object
Pinned host-only live execution capability. It is not installed in an application context.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.j7m.middleware.distributed.ExecutionClient
    client()
    Returns the exact fixed client for every mutation and query of this live claim.
    long
    epoch()
    Returns the immutable pinned partition epoch, not a current authority assertion.
    String
    group()
    Returns the actual pinned physical group.
    org.j7m.middleware.distributed.DurableJobs
    jobs()
    Returns ownership-fenced job operations on this exact session.
    org.j7m.middleware.distributed.DurableSagas
    sagas()
    Returns ownership-fenced saga operations on this exact session.
    org.j7m.middleware.distributed.ExecutionSession
    subscribe(String prefix, String kind, String owner, long leaseMillis, Instant deadline)
    Opens direct native claim push on this exact captured group and epoch.
    String
    toString()
    Omits scope, endpoints and credentials.
    void
    verify(Instant deadline)
    Checks current quorum ownership without changing the captured route.

    Methods inherited from class Object

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

  • Method Details

    • group

      public String group()
      Returns the actual pinned physical group.
      Returns:
      stable trusted group identity

    • epoch

      public long epoch()
      Returns the immutable pinned partition epoch, not a current authority assertion.
      Returns:
      captured positive epoch

    • client

      public org.j7m.middleware.distributed.ExecutionClient client()
      Returns the exact fixed client for every mutation and query of this live claim.
      Returns:
      host-only client which never follows MOVED

    • jobs

      public org.j7m.middleware.distributed.DurableJobs jobs()
      Returns ownership-fenced job operations on this exact session.
      Returns:
      job facade

    • sagas

      public org.j7m.middleware.distributed.DurableSagas sagas()
      Returns ownership-fenced saga operations on this exact session.
      Returns:
      saga facade

    • subscribe

      public org.j7m.middleware.distributed.ExecutionSession subscribe(String prefix, String kind, String owner, long leaseMillis, Instant deadline) throws IOException
      Opens direct native claim push on this exact captured group and epoch. A reconnect creates a new session rather than retargeting an already running claim.
      Parameters:
      prefix - finite run identity prefix
      kind - JOB or SAGA
      owner - host-generated unique worker identity
      leaseMillis - finite native claim lease
      deadline - original handshake budget
      Returns:
      owned transport session, without ownership of borrowed backend endpoints
      Throws:
      IOException - for revoked ownership or unavailable push capability

    • verify

      public void verify(Instant deadline) throws IOException
      Checks current quorum ownership without changing the captured route.
      Parameters:
      deadline - original verification deadline
      Throws:
      IOException - if group, epoch or phase no longer permits effects

    • toString

      public String toString()
      Omits scope, endpoints and credentials.
      Overrides:
      toString in class Object
      Returns:
      safe fixed diagnostic