Uses of Interface
org.apache.qpid.protonj2.types.transport.Performative.PerformativeHandler
Package
Description
-
Uses of Performative.PerformativeHandler in org.apache.qpid.protonj2.codec
Modifier and TypeClassDescriptionfinal class
AMQP Performative type specific encoder that uses anyEncoder
to cache the specific type encoders for various section types and use them directly instead of looking them up via calls toEncoder.writeObject(org.apache.qpid.protonj2.buffer.ProtonBuffer, EncoderState, Object)
-
Uses of Performative.PerformativeHandler in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescription<E> void
EmptyEnvelope.invoke
(Performative.PerformativeHandler<E> handler, E context) <E> void
IncomingAMQPEnvelope.invoke
(Performative.PerformativeHandler<E> handler, E context) Invoke the correct PerformativeHandler event based on the body of thisIncomingAMQPEnvelope
<E> void
OutgoingAMQPEnvelope.invoke
(Performative.PerformativeHandler<E> handler, E context) Invoke the correct PerformativeHandler event based on the body of thisOutgoingAMQPEnvelope
-
Uses of Performative.PerformativeHandler in org.apache.qpid.protonj2.engine.impl
Modifier and TypeClassDescriptionclass
Implements the proton Connection APIclass
Transport Handler that forwards the incoming Performatives to the associated Connection as well as any error encountered during the Transport processing. -
Uses of Performative.PerformativeHandler in org.apache.qpid.protonj2.types.transport
Modifier and TypeMethodDescription<E> void
Attach.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Begin.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Close.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Detach.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Disposition.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
End.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Flow.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Open.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Performative.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context) <E> void
Transfer.invoke
(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)