Uses of Interface
org.apache.qpid.protonj2.engine.Engine
Package
Description
-
Uses of Engine in org.apache.qpid.protonj2.client.impl
Modifier and TypeMethodDescriptionprotected final void
ClientLinkType.handleEngineShutdown
(Engine engine) -
Uses of Engine in org.apache.qpid.protonj2.engine
Modifier 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.Modifier 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
Modifier and TypeMethodDescriptionProtonEngineFactory.createEngine()
ProtonEngineFactory.createNonSaslEngine()
ProtonEngineHandlerContext.engine()
Modifier and TypeMethodDescriptionProtonEndpoint.engineShutdownHandler
(EventHandler<Engine> engineShutdownEventHandler) ProtonEngine.errorHandler
(EventHandler<Engine> handler) ProtonEngine.shutdownHandler
(EventHandler<Engine> handler) ModifierConstructorDescriptionProtonEngineHandlerContext
(String name, Engine engine, EngineHandler handler) Creates a newProtonEngineHandlerContext
with the given options.