Uses of Interface
org.apache.qpid.protonj2.engine.Engine
-
Packages that use Engine Package Description org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl -
-
Uses of Engine in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return Engine Modifier and Type Method Description EngineEngineFactory. createEngine()Create a new Engine instance with a SASL authentication layer added.EngineEngineFactory. createNonSaslEngine()Create a new Engine instance that handles only raw AMQP with no SASL layer enabled.EngineEngineHandlerContext. engine()EngineEnginePipeline. engine()EngineEngine. errorHandler(EventHandler<Engine> engineFailure)Sets a handler instance that will be notified when the engine encounters a fatal error.EngineEndpoint. getEngine()EngineEngine. ingest(ProtonBuffer input)Provide data input for this Engine from some external source.default EngineEngine. outputConsumer(java.util.function.Consumer<ProtonBuffer> consumer)Sets aConsumerinstance that will be notified when data from the engine is ready to be written to some output sink (socket etc).EngineEngine. outputHandler(java.util.function.BiConsumer<ProtonBuffer,java.lang.Runnable> output)Sets aBiConsumerinstance that will be notified when data from the engine is ready to be written to some output sink (socket etc).default EngineEngine. outputHandler(EventHandler<ProtonBuffer> output)Sets a handler instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).EngineEngine. shutdown()Shutdown the engine preventing any future outbound or inbound processing.EngineEngine. shutdownHandler(EventHandler<Engine> engineShutdownEventHandler)Sets a handler instance that will be notified when the engine is shut down via a call to theshutdown()method is called.EngineEngine. tickAuto(java.util.concurrent.ScheduledExecutorService executor)Allows the engine to manage idle timeout processing by providing it the single threaded executor context where all transport work is done which ensures singled threaded access while removing the need for the client library or server application to manage calls to thetick(long)methods.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type Engine Modifier and Type Method Description EEndpoint. engineShutdownHandler(EventHandler<Engine> engineShutdownEventHandler)Sets anEventHandlerthat is invoked when the engine that supports thisEndpointis shutdown via a call toshutdown()which indicates a desire to terminate all engine operations.EngineEngine. errorHandler(EventHandler<Engine> engineFailure)Sets a handler instance that will be notified when the engine encounters a fatal error.EngineEngine. shutdownHandler(EventHandler<Engine> engineShutdownEventHandler)Sets a handler instance that will be notified when the engine is shut down via a call to theshutdown()method is called. -
Uses of Engine in org.apache.qpid.protonj2.engine.impl
Classes in org.apache.qpid.protonj2.engine.impl that implement Engine Modifier and Type Class Description classProtonEngineThe default proton Engine implementation.Methods in org.apache.qpid.protonj2.engine.impl that return Engine Modifier and Type Method Description EngineProtonEngineFactory. createEngine()EngineProtonEngineFactory. createNonSaslEngine()EngineProtonEngineHandlerContext. engine()Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type Engine Modifier and Type Method Description EProtonEndpoint. engineShutdownHandler(EventHandler<Engine> engineShutdownEventHandler)ProtonEngineProtonEngine. errorHandler(EventHandler<Engine> handler)ProtonEngineProtonEngine. shutdownHandler(EventHandler<Engine> handler)Constructors in org.apache.qpid.protonj2.engine.impl with parameters of type Engine Constructor Description ProtonEngineHandlerContext(java.lang.String name, Engine engine, EngineHandler handler)Creates a newProtonEngineHandlerContextwith the given options.
-