Uses of Interface
org.apache.qpid.protonj2.engine.Engine
Packages that use Engine
Package
Description
-
Uses of Engine in org.apache.qpid.protonj2.client.impl
Methods in org.apache.qpid.protonj2.client.impl with parameters of type EngineModifier and TypeMethodDescriptionprotected final void
ClientLinkType.handleEngineShutdown
(Engine engine) -
Uses of Engine in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return EngineModifier and TypeMethodDescriptionEngineFactory.createEngine()
Create a new Engine instance with a SASL authentication layer added.EngineFactory.createNonSaslEngine()
Create a new Engine instance that handles only raw AMQP with no SASL layer enabled.EngineHandlerContext.engine()
EnginePipeline.engine()
Engine.errorHandler
(EventHandler<Engine> engineFailure) Sets a handler instance that will be notified when the engine encounters a fatal error.Endpoint.getEngine()
Engine.ingest
(ProtonBuffer input) Provide data input for this Engine from some external source.default Engine
Engine.outputConsumer
(Consumer<ProtonBuffer> consumer) Sets aConsumer
instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).Engine.outputHandler
(BiConsumer<ProtonBuffer, Runnable> output) Sets aBiConsumer
instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).default Engine
Engine.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).Engine.shutdown()
Shutdown the engine preventing any future outbound or inbound processing.Engine.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.Engine.tickAuto
(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.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 EngineModifier and TypeMethodDescriptionEndpoint.engineShutdownHandler
(EventHandler<Engine> engineShutdownEventHandler) Sets anEventHandler
that is invoked when the engine that supports thisEndpoint
is shutdown via a call toshutdown()
which indicates a desire to terminate all engine operations.Engine.errorHandler
(EventHandler<Engine> engineFailure) Sets a handler instance that will be notified when the engine encounters a fatal error.Engine.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 EngineMethods in org.apache.qpid.protonj2.engine.impl that return EngineModifier and TypeMethodDescriptionProtonEngineFactory.createEngine()
ProtonEngineFactory.createNonSaslEngine()
ProtonEngineHandlerContext.engine()
Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type EngineModifier and TypeMethodDescriptionProtonEndpoint.engineShutdownHandler
(EventHandler<Engine> engineShutdownEventHandler) ProtonEngine.errorHandler
(EventHandler<Engine> handler) ProtonEngine.shutdownHandler
(EventHandler<Engine> handler) Constructors in org.apache.qpid.protonj2.engine.impl with parameters of type EngineModifierConstructorDescriptionProtonEngineHandlerContext
(String name, Engine engine, EngineHandler handler) Creates a newProtonEngineHandlerContext
with the given options.