Uses of Class
org.apache.qpid.protonj2.engine.impl.ProtonEngine
-
Uses of ProtonEngine in org.apache.qpid.protonj2.engine.impl
Modifier and TypeMethodDescriptionProtonEnginePipeline.engine()
ProtonEnginePipelineProxy.engine()
ProtonEngine.errorHandler
(EventHandler<Engine> handler) ProtonEndpoint.getEngine()
ProtonEngine.ingest
(ProtonBuffer input) ProtonEngine.outputHandler
(BiConsumer<ProtonBuffer, Runnable> handler) ProtonEngine.shutdown()
ProtonEngine.shutdownHandler
(EventHandler<Engine> handler) ProtonEngine.tickAuto
(ScheduledExecutorService executor) Modifier and TypeMethodDescriptionvoid
ProtonConnection.handleAMQPHeader
(AMQPHeader header, ProtonEngine context) void
ProtonConnection.handleAttach
(Attach attach, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleBegin
(Begin begin, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleClose
(Close close, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleDetach
(Detach detach, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleDisposition
(Disposition disposition, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleEnd
(End end, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleFlow
(Flow flow, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleOpen
(Open open, ProtonBuffer payload, int channel, ProtonEngine context) void
ProtonConnection.handleSASLHeader
(AMQPHeader header, ProtonEngine context) void
ProtonConnection.handleTransfer
(Transfer transfer, ProtonBuffer payload, int channel, ProtonEngine context) ModifierConstructorDescriptionProtonEndpoint
(ProtonEngine engine) Create a newProtonEndpoint
instance with the given Engine as the owner.