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 Engine
EngineFactory. createEngine()
Create a new Engine instance with a SASL authentication layer added.Engine
EngineFactory. createNonSaslEngine()
Create a new Engine instance that handles only raw AMQP with no SASL layer enabled.Engine
EngineHandlerContext. engine()
Engine
EnginePipeline. engine()
Engine
Engine. errorHandler(EventHandler<Engine> engineFailure)
Sets a handler instance that will be notified when the engine encounters a fatal error.Engine
Endpoint. getEngine()
Engine
Engine. ingest(ProtonBuffer input)
Provide data input for this Engine from some external source.default Engine
Engine. outputConsumer(java.util.function.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
Engine. outputHandler(java.util.function.BiConsumer<ProtonBuffer,java.lang.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
Engine. shutdown()
Shutdown the engine preventing any future outbound or inbound processing.Engine
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
Engine. 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 E
Endpoint. 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
Engine. errorHandler(EventHandler<Engine> engineFailure)
Sets a handler instance that will be notified when the engine encounters a fatal error.Engine
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 Engine Modifier and Type Class Description class
ProtonEngine
The default proton Engine implementation.Methods in org.apache.qpid.protonj2.engine.impl that return Engine Modifier and Type Method Description Engine
ProtonEngineFactory. createEngine()
Engine
ProtonEngineFactory. createNonSaslEngine()
Engine
ProtonEngineHandlerContext. engine()
Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type Engine Modifier and Type Method Description E
ProtonEndpoint. engineShutdownHandler(EventHandler<Engine> engineShutdownEventHandler)
ProtonEngine
ProtonEngine. errorHandler(EventHandler<Engine> handler)
ProtonEngine
ProtonEngine. 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 newProtonEngineHandlerContext
with the given options.
-