Class RealtimeExecutor

java.lang.Object

com.kingsrook.qqq.middleware.javalin.executors.AbstractMiddlewareExecutor<RealtimeExecutor.Input,RealtimeExecutor.Output>

com.kingsrook.qqq.middleware.javalin.realtime.RealtimeExecutor

public class RealtimeExecutor
extends AbstractMiddlewareExecutor<RealtimeExecutor.Input,RealtimeExecutor.Output>

Transport-neutral subscription executor; stream attachment is done in handleOutput.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RealtimeExecutor.Input	Internal execution input; wire schemas are separate components.
static class	RealtimeExecutor.Output	Internal execution output; never serialized as a wire payload.

Constructor Summary

Constructors

Constructor	Description
RealtimeExecutor()

Method Summary

Modifier and Type	Method	Description
void	execute(RealtimeExecutor.Input input, RealtimeExecutor.Output output)	Pass the stream hub to the output or apply a subscription request.

Methods inherited from class java.lang.Object

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

Constructor Details

RealtimeExecutor

public RealtimeExecutor()

Method Details

execute

public void execute(RealtimeExecutor.Input input,
 RealtimeExecutor.Output output)
             throws QException

Pass the stream hub to the output or apply a subscription request.

Specified by:

execute in class AbstractMiddlewareExecutor<RealtimeExecutor.Input,RealtimeExecutor.Output>

Throws:

QException