Uses of Class
org.apache.qpid.protonj2.engine.exceptions.EngineStateException
-
Packages that use EngineStateException Package Description org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.exceptions org.apache.qpid.protonj2.engine.impl org.apache.qpid.protonj2.engine.sasl -
-
Uses of EngineStateException in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return EngineStateException Modifier and Type Method Description EngineStateExceptionEngine. engineFailed(java.lang.Throwable cause)Transition theEngineto a failed state if not already closed or closing.Methods in org.apache.qpid.protonj2.engine that throw EngineStateException Modifier and Type Method Description default voidEngine. accept(ProtonBuffer input)Provide data input for this Engine from some external source.EngineEngine. ingest(ProtonBuffer input)Provide data input for this Engine from some external source.ConnectionConnection. negotiate()If not already negotiated this method initiates the AMQP protocol negotiation phase of the connection process sending theAMQPHeaderto the remote peer.ConnectionConnection. negotiate(EventHandler<AMQPHeader> remoteAMQPHeaderHandler)If not already negotiated this method initiates the AMQP protocol negotiation phase of the connection process sending theAMQPHeaderto the remote peer.EEndpoint. open()Open the end point locally, sending the Open performative immediately if possible or holding it until SASL negotiations or the AMQP header exchange and other required performative exchanges has completed.ConnectionEngine. start()Starts the engine and returns theConnectioninstance that is bound to this Engine.longConnection. tick(long current)Performs a tick operation on the connection which checks that Connection Idle timeout processing is run.longEngine. tick(long currentTime)Prompt the engine to perform idle-timeout/heartbeat handling, and return an absolute deadline in milliseconds that tick must again be called by/at, based on the provided current time in milliseconds, to ensure the periodic work is carried out as necessary.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 theEngine.tick(long)methods. -
Uses of EngineStateException in org.apache.qpid.protonj2.engine.exceptions
Subclasses of EngineStateException in org.apache.qpid.protonj2.engine.exceptions Modifier and Type Class Description classEngineFailedExceptionThrown from Engine API methods that attempted an operation what would have resulted in a write of data or other state modification after the engine has entered the the failed state.classEngineNotStartedExceptionThrown when a read or write operation is attempted on the engine before it has been properly started.classEngineNotWritableExceptionException indicating that the engine is not currently accepting input of dataclassEngineShutdownExceptionException thrown when an option is performed on a closed engine.classEngineStartedExceptionThrown when an API method has been called which cannot be allowed to proceed due to the engine having already been started and doesn't allow modification to the resource in question after that point. -
Uses of EngineStateException in org.apache.qpid.protonj2.engine.impl
Methods in org.apache.qpid.protonj2.engine.impl that return EngineStateException Modifier and Type Method Description EngineStateExceptionProtonEngine. engineFailed(java.lang.Throwable cause)Methods in org.apache.qpid.protonj2.engine.impl that throw EngineStateException Modifier and Type Method Description ProtonEngineProtonEngine. ingest(ProtonBuffer input)ProtonConnectionProtonConnection. open()ProtonSessionProtonSession. open()TransactionControllerProtonTransactionController. open()TransactionManagerProtonTransactionManager. open()voidProtonEngine. registerSaslDriver(EngineSaslDriver saslDriver)Allows for registration of a customEngineSaslDriverthat will convey SASL state and configuration for this engine.ProtonConnectionProtonEngine. start()longProtonEngine. tick(long currentTime)ProtonEngineProtonEngine. tickAuto(java.util.concurrent.ScheduledExecutorService executor) -
Uses of EngineStateException in org.apache.qpid.protonj2.engine.sasl
Methods in org.apache.qpid.protonj2.engine.sasl that throw EngineStateException Modifier and Type Method Description SaslServerContextSaslServerContext. sendChallenge(ProtonBuffer challenge)Sends the SASL challenge defined by the SASL mechanism that is in use during this SASL negotiation.SaslClientContextSaslClientContext. sendChosenMechanism(Symbol mechanism, java.lang.String host, ProtonBuffer initialResponse)Sends a response to the SASL server indicating the chosen mechanism for this client and the host name that this client is identifying itself as.SaslServerContextSaslServerContext. sendMechanisms(Symbol[] mechanisms)Sends the set of supported mechanisms to the SASL client from which it must choose and return one mechanism which will then be the basis for the SASL authentication negotiation.SaslServerContextSaslServerContext. sendOutcome(SaslOutcome outcome, ProtonBuffer additional)Sends a response to a server side challenge that comprises the challenge / response exchange for the chosen SASL mechanism.SaslClientContextSaslClientContext. sendResponse(ProtonBuffer response)Sends a response to a server side challenge that comprises the challenge / response exchange for the chosen SASL mechanism.SaslClientContextSaslClientContext. sendSASLHeader()Sends the AMQP Header indicating the desire for SASL negotiations to be commenced on this connection.
-