Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.fasterxml.jackson.core/jackson-annotations/2.11.3
- com.fasterxml.jackson.core/jackson-core/2.11.3
- com.fasterxml.jackson.core/jackson-databind/2.11.3
- com.github.jponge/lzma-java/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- io.netty/netty-buffer/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-haproxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-tcnative/2.0.30.Final
- io.netty/netty-transport/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.projectreactor.tools/blockhound/1.0.3.RELEASE
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-core/4.0.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.apache.qpid/proton-j/0.33.8
- org.bouncycastle/bcpkix-jdk15on/1.65
- org.bouncycastle/bcprov-jdk15on/1.65
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.slf4j/slf4j-api/1.7.21
Declarations
- examples
-
io
-
vertx
-
proton
-
ProtonClient
- create(Vertx): ProtonClient
- connect(String, int, Handler<AsyncResult<ProtonConnection>>): void
- connect(String, int, String, String, Handler<AsyncResult<ProtonConnection>>): void
- connect(ProtonClientOptions, String, int, Handler<AsyncResult<ProtonConnection>>): void
- connect(ProtonClientOptions, String, int, String, String, Handler<AsyncResult<ProtonConnection>>): void
-
ProtonClientOptions
- setReceiveBufferSize(int): ProtonClientOptions
- ProtonClientOptions(): void
- enabledSaslMechanisms: Set<String>
- heartbeat: int
- maxFrameSize: int
- virtualHost: String
- sniServerName: String
- ProtonClientOptions(ProtonClientOptions): void
- ProtonClientOptions(JsonObject): void
- toJson(): JsonObject
- getEnabledSaslMechanisms(): Set<String>
- addEnabledSaslMechanism(String): ProtonClientOptions
- setSendBufferSize(int): ProtonClientOptions
- setReuseAddress(boolean): ProtonClientOptions
- setTrafficClass(int): ProtonClientOptions
- setTcpNoDelay(boolean): ProtonClientOptions
- setTcpKeepAlive(boolean): ProtonClientOptions
- setSoLinger(int): ProtonClientOptions
- setIdleTimeout(int): ProtonClientOptions
- setIdleTimeoutUnit(TimeUnit): ProtonClientOptions
- setSsl(boolean): ProtonClientOptions
- setKeyStoreOptions(JksOptions): ProtonClientOptions
- setPfxKeyCertOptions(PfxOptions): ProtonClientOptions
- setPemKeyCertOptions(PemKeyCertOptions): ProtonClientOptions
- setTrustStoreOptions(JksOptions): ProtonClientOptions
- setPemTrustOptions(PemTrustOptions): ProtonClientOptions
- setPfxTrustOptions(PfxOptions): ProtonClientOptions
- addEnabledCipherSuite(String): ProtonClientOptions
- addCrlPath(String): ProtonClientOptions
- addCrlValue(Buffer): ProtonClientOptions
- setTrustAll(boolean): ProtonClientOptions
- setConnectTimeout(int): ProtonClientOptions
- setReconnectAttempts(int): ProtonClientOptions
- setReconnectInterval(long): ProtonClientOptions
- hashCode(): int
- equals(Object): boolean
- setUseAlpn(boolean): ProtonClientOptions
- addEnabledSecureTransportProtocol(String): ProtonClientOptions
- setHostnameVerificationAlgorithm(String): ProtonClientOptions
- setKeyCertOptions(KeyCertOptions): ProtonClientOptions
- setLogActivity(boolean): ProtonClientOptions
- setMetricsName(String): ProtonClientOptions
- setProxyOptions(ProxyOptions): ProtonClientOptions
- setTrustOptions(TrustOptions): ProtonClientOptions
- setJdkSslEngineOptions(JdkSSLEngineOptions): ProtonClientOptions
- setOpenSslEngineOptions(OpenSSLEngineOptions): ProtonClientOptions
- setSslEngineOptions(SSLEngineOptions): ProtonClientOptions
- setSslHandshakeTimeout(long): ProtonClientOptions
- setSslHandshakeTimeoutUnit(TimeUnit): ProtonClientOptions
- setLocalAddress(String): ProtonClientOptions
- setReusePort(boolean): ProtonClientOptions
- setTcpCork(boolean): ProtonClientOptions
- setTcpFastOpen(boolean): ProtonClientOptions
- setTcpQuickAck(boolean): ProtonClientOptions
- removeEnabledSecureTransportProtocol(String): ProtonClientOptions
- setEnabledSecureTransportProtocols(Set<String>): ProtonClientOptions
- setVirtualHost(String): ProtonClientOptions
- getVirtualHost(): String
- setSniServerName(String): ProtonClientOptions
- getSniServerName(): String
- setHeartbeat(int): ProtonClientOptions
- getHeartbeat(): int
- setMaxFrameSize(int): ProtonClientOptions
- getMaxFrameSize(): int
- ProtonClientOptionsConverter
-
ProtonConnection
- open(): ProtonConnection
- close(): ProtonConnection
- createReceiver(String): ProtonReceiver
- createReceiver(String, ProtonLinkOptions): ProtonReceiver
- createSender(String): ProtonSender
- createSender(String, ProtonLinkOptions): ProtonSender
- setContainer(String): ProtonConnection
- getContainer(): String
- attachments(): Record
- setProperties(Map<Symbol, Object>): ProtonConnection
- getRemoteProperties(): Map<Symbol, Object>
- isAnonymousRelaySupported(): boolean
- createSession(): ProtonSession
- disconnect(): void
- isDisconnected(): boolean
- setHostname(String): ProtonConnection
- getHostname(): String
- getRemoteContainer(): String
- setDesiredCapabilities(Symbol[]): ProtonConnection
- getRemoteDesiredCapabilities(): Symbol[]
- setOfferedCapabilities(Symbol[]): ProtonConnection
- getRemoteOfferedCapabilities(): Symbol[]
- getRemoteHostname(): String
- setCondition(ErrorCondition): ProtonConnection
- getCondition(): ErrorCondition
- getRemoteCondition(): ErrorCondition
- openHandler(Handler<AsyncResult<ProtonConnection>>): ProtonConnection
- closeHandler(Handler<AsyncResult<ProtonConnection>>): ProtonConnection
- sessionOpenHandler(Handler<ProtonSession>): ProtonConnection
- senderOpenHandler(Handler<ProtonSender>): ProtonConnection
- receiverOpenHandler(Handler<ProtonReceiver>): ProtonConnection
- disconnectHandler(Handler<ProtonConnection>): ProtonConnection
- ProtonDelivery
-
ProtonHelper
- message(): Message
- message(String): Message
- message(String, String): Message
- condition(Symbol, String): ErrorCondition
- condition(String, String): ErrorCondition
- tag(String): byte[]
- accepted(ProtonDelivery, boolean): ProtonDelivery
- rejected(ProtonDelivery, boolean): ProtonDelivery
- released(ProtonDelivery, boolean): ProtonDelivery
- modified(ProtonDelivery, boolean, boolean, boolean): ProtonDelivery
- future(Object, ErrorCondition): AsyncResult<Object>
-
ProtonLink
- getName(): String
- getSession(): ProtonSession
- getRemoteAddress(): String
- open(): ProtonLink
- close(): ProtonLink
- detach(): ProtonLink
- openHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
- closeHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
- detachHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
- getQoS(): ProtonQoS
- setQoS(ProtonQoS): ProtonLink
- getRemoteQoS(): ProtonQoS
- isOpen(): boolean
- attachments(): Record
- getTarget(): Target
- setTarget(Target): ProtonLink
- getRemoteTarget(): Target
- getSource(): Source
- setSource(Source): ProtonLink
- getRemoteSource(): Source
- setCondition(ErrorCondition): ProtonLink
- getCondition(): ErrorCondition
- getRemoteCondition(): ErrorCondition
- getCredit(): int
- getDrain(): boolean
- getQueued(): int
- setMaxMessageSize(UnsignedLong): void
- getMaxMessageSize(): UnsignedLong
- getRemoteMaxMessageSize(): UnsignedLong
- setProperties(Map<Symbol, Object>): void
- getRemoteProperties(): Map<Symbol, Object>
- setOfferedCapabilities(Symbol[]): void
- getRemoteOfferedCapabilities(): Symbol[]
- setDesiredCapabilities(Symbol[]): void
- getRemoteDesiredCapabilities(): Symbol[]
- free(): void
- ProtonLinkOptions
- ProtonLinkOptionsConverter
- ProtonMessageHandler
- ProtonQoS
-
ProtonReceiver
- getPrefetch(): int
- handler(ProtonMessageHandler): ProtonReceiver
- setPrefetch(int): ProtonReceiver
- setAutoAccept(boolean): ProtonReceiver
- isAutoAccept(): boolean
- flow(int): ProtonReceiver
- drain(long, Handler<AsyncResult<Void>>): ProtonReceiver
- maxMessageSizeExceededHandler(Handler<ProtonReceiver>): ProtonReceiver
-
ProtonSender
- send(Message): ProtonDelivery
- send(Message, Handler<ProtonDelivery>): ProtonDelivery
- send(byte[], Message): ProtonDelivery
- send(byte[], Message, Handler<ProtonDelivery>): ProtonDelivery
- sendQueueFull(): boolean
- sendQueueDrainHandler(Handler<ProtonSender>): ProtonSender
- setAutoSettle(boolean): ProtonSender
- isAutoSettle(): boolean
- setAutoDrained(boolean): ProtonSender
- isAutoDrained(): boolean
- drained(): int
-
ProtonServer
- create(Vertx): ProtonServer
- create(Vertx, ProtonServerOptions): ProtonServer
- connectHandler(Handler<ProtonConnection>): ProtonServer
- connectHandler(): Handler<ProtonConnection>
- saslAuthenticatorFactory(ProtonSaslAuthenticatorFactory): ProtonServer
- actualPort(): int
- listen(int, String, Handler<AsyncResult<ProtonServer>>): ProtonServer
- listen(int, Handler<AsyncResult<ProtonServer>>): ProtonServer
- listen(Handler<AsyncResult<ProtonServer>>): ProtonServer
- listen(int): ProtonServer
- listen(int, String): ProtonServer
- listen(): ProtonServer
- close(): void
- close(Handler<AsyncResult<Void>>): void
-
ProtonServerOptions
- setOpenSslEngineOptions(OpenSSLEngineOptions): ProtonServerOptions
- heartbeat: int
- maxFrameSize: int
- ProtonServerOptions(): void
- ProtonServerOptions(ProtonServerOptions): void
- ProtonServerOptions(JsonObject): void
- toJson(): JsonObject
- setSendBufferSize(int): ProtonServerOptions
- setReceiveBufferSize(int): ProtonServerOptions
- setReuseAddress(boolean): ProtonServerOptions
- setTrafficClass(int): ProtonServerOptions
- setTcpNoDelay(boolean): ProtonServerOptions
- setTcpKeepAlive(boolean): ProtonServerOptions
- setSoLinger(int): ProtonServerOptions
- setIdleTimeout(int): ProtonServerOptions
- setIdleTimeoutUnit(TimeUnit): ProtonServerOptions
- setSsl(boolean): ProtonServerOptions
- setKeyStoreOptions(JksOptions): ProtonServerOptions
- setPfxKeyCertOptions(PfxOptions): ProtonServerOptions
- setPemKeyCertOptions(PemKeyCertOptions): ProtonServerOptions
- setTrustStoreOptions(JksOptions): ProtonServerOptions
- setPfxTrustOptions(PfxOptions): ProtonServerOptions
- setPemTrustOptions(PemTrustOptions): ProtonServerOptions
- addEnabledCipherSuite(String): ProtonServerOptions
- addCrlPath(String): ProtonServerOptions
- addCrlValue(Buffer): ProtonServerOptions
- setAcceptBacklog(int): ProtonServerOptions
- setPort(int): ProtonServerOptions
- setHost(String): ProtonServerOptions
- setClientAuth(ClientAuth): ProtonServerOptions
- hashCode(): int
- equals(Object): boolean
- setUseAlpn(boolean): ProtonServerOptions
- addEnabledSecureTransportProtocol(String): ProtonServerOptions
- removeEnabledSecureTransportProtocol(String): ProtonServerOptions
- setEnabledSecureTransportProtocols(Set<String>): ProtonServerOptions
- setJdkSslEngineOptions(JdkSSLEngineOptions): ProtonServerOptions
- setKeyCertOptions(KeyCertOptions): ProtonServerOptions
- setSslEngineOptions(SSLEngineOptions): ProtonServerOptions
- setSslHandshakeTimeout(long): ProtonServerOptions
- setSslHandshakeTimeoutUnit(TimeUnit): ProtonServerOptions
- setTrustOptions(TrustOptions): ProtonServerOptions
- setLogActivity(boolean): ProtonServerOptions
- setSni(boolean): ProtonServerOptions
- setReusePort(boolean): ProtonServerOptions
- setTcpFastOpen(boolean): ProtonServerOptions
- setTcpCork(boolean): ProtonServerOptions
- setTcpQuickAck(boolean): ProtonServerOptions
- setHeartbeat(int): ProtonServerOptions
- getHeartbeat(): int
- setMaxFrameSize(int): ProtonServerOptions
- getMaxFrameSize(): int
- ProtonServerOptionsConverter
-
ProtonSession
- getIncomingCapacity(): int
- getConnection(): ProtonConnection
- createReceiver(String): ProtonReceiver
- createReceiver(String, ProtonLinkOptions): ProtonReceiver
- createSender(String): ProtonSender
- createSender(String, ProtonLinkOptions): ProtonSender
- open(): ProtonSession
- close(): ProtonSession
- attachments(): Record
- setIncomingCapacity(int): ProtonSession
- setCondition(ErrorCondition): ProtonSession
- getCondition(): ErrorCondition
- getRemoteCondition(): ErrorCondition
- openHandler(Handler<AsyncResult<ProtonSession>>): ProtonSession
- closeHandler(Handler<AsyncResult<ProtonSession>>): ProtonSession
- free(): void
- ProtonTransportOptions
- ProtonTransportOptionsConverter
-
impl
-
ProtonClientImpl
- LOG: Logger
- vertx: Vertx
- ProtonClientImpl(Vertx): void
- connect(String, int, Handler<AsyncResult<ProtonConnection>>): void
- connect(String, int, String, String, Handler<AsyncResult<ProtonConnection>>): void
- connect(ProtonClientOptions, String, int, Handler<AsyncResult<ProtonConnection>>): void
- connect(ProtonClientOptions, String, int, String, String, Handler<AsyncResult<ProtonConnection>>): void
- connectNetClient(NetClient, String, int, String, String, ConnectCompletionHandler, ProtonClientOptions): void
- ConnectCompletionHandler
-
ProtonConnectionImpl
- LOG: Logger
- ANONYMOUS_RELAY: Symbol
- connection: Connection
- vertx: Vertx
- connCtx: ContextInternal
- transport: ProtonTransport
- endHandlers: List<Handler<Void>>
- openHandler: Handler<AsyncResult<ProtonConnection>>
- closeHandler: Handler<AsyncResult<ProtonConnection>>
- disconnectHandler: Handler<ProtonConnection>
- sessionOpenHandler: Handler<ProtonSession>
- senderOpenHandler: Handler<ProtonSender>
- receiverOpenHandler: Handler<ProtonReceiver>
- anonymousRelaySupported: boolean
- defaultSession: ProtonSession
- ProtonConnectionImpl(Vertx, String, ContextInternal): void
- createInitialPropertiesMap(): LinkedHashMap<Symbol, Object>
- setProperties(Map<Symbol, Object>): ProtonConnectionImpl
- setOfferedCapabilities(Symbol[]): ProtonConnectionImpl
- setHostname(String): ProtonConnectionImpl
- setDesiredCapabilities(Symbol[]): ProtonConnectionImpl
- setContainer(String): ProtonConnectionImpl
- setCondition(ErrorCondition): ProtonConnectionImpl
- getCondition(): ErrorCondition
- getContainer(): String
- getHostname(): String
- getLocalState(): EndpointState
- getRemoteCondition(): ErrorCondition
- getRemoteContainer(): String
- getRemoteDesiredCapabilities(): Symbol[]
- getRemoteHostname(): String
- getRemoteOfferedCapabilities(): Symbol[]
- getRemoteProperties(): Map<Symbol, Object>
- getRemoteState(): EndpointState
- isAnonymousRelaySupported(): boolean
- attachments(): Record
- open(): ProtonConnection
- close(): ProtonConnection
- createSession(): ProtonSessionImpl
- getDefaultSession(): ProtonSession
- createSender(String): ProtonSender
- createSender(String, ProtonLinkOptions): ProtonSender
- createReceiver(String): ProtonReceiver
- createReceiver(String, ProtonLinkOptions): ProtonReceiver
- flush(): void
- disconnect(): void
- isDisconnected(): boolean
- openHandler(Handler<AsyncResult<ProtonConnection>>): ProtonConnection
- closeHandler(Handler<AsyncResult<ProtonConnection>>): ProtonConnection
- disconnectHandler(Handler<ProtonConnection>): ProtonConnection
- sessionOpenHandler(Handler<ProtonSession>): ProtonConnection
- senderOpenHandler(Handler<ProtonSender>): ProtonConnection
- receiverOpenHandler(Handler<ProtonReceiver>): ProtonConnection
- processCapabilities(): void
- fireRemoteOpen(): void
- fireRemoteClose(): void
- fireDisconnect(): void
- bindClient(NetClient, NetSocket, ProtonSaslClientAuthenticatorImpl, ProtonTransportOptions): void
- bindServer(NetSocket, ProtonSaslAuthenticator, ProtonTransportOptions): void
- fireRemoteSessionOpen(Session): void
- fireRemoteLinkOpen(Link): void
- addEndHandler(Handler<Void>): void
- getContext(): ContextInternal
-
ProtonDeliveryImpl
- delivery: Delivery
- handler: Handler<ProtonDelivery>
- autoSettle: boolean
- ProtonDeliveryImpl(Delivery): void
- getLink(): ProtonLinkImpl
- clear(): void
- getLocalState(): DeliveryState
- isSettled(): boolean
- remotelySettled(): boolean
- attachments(): Record
- getTag(): byte[]
- setDefaultDeliveryState(DeliveryState): void
- getDefaultDeliveryState(): DeliveryState
- isReadable(): boolean
- isUpdated(): boolean
- isWritable(): boolean
- pending(): int
- isPartial(): boolean
- getRemoteState(): DeliveryState
- getMessageFormat(): int
- isBuffered(): boolean
- disposition(DeliveryState, boolean): ProtonDelivery
- settle(): ProtonDelivery
- flushConnection(): void
- handler(Handler<ProtonDelivery>): ProtonDelivery
- isAutoSettle(): boolean
- setAutoSettle(boolean): void
- fireUpdate(): void
- getLinkImpl(): ProtonLinkImpl
-
ProtonLinkImpl
- delivery(byte[]): Delivery
- link: Link
- openHandler: Handler<AsyncResult<ProtonLink>>
- closeHandler: Handler<AsyncResult<ProtonLink>>
- detachHandler: Handler<AsyncResult<ProtonLink>>
- ProtonLinkImpl(Link): void
- self(): ProtonLink
- getSession(): ProtonSessionImpl
- attachments(): Record
- getCondition(): ErrorCondition
- getCredit(): int
- getDrain(): boolean
- getLocalState(): EndpointState
- getName(): String
- getRemoteCondition(): ErrorCondition
- getRemoteCredit(): int
- getRemoteState(): EndpointState
- getRemoteTarget(): Target
- getTarget(): Target
- setTarget(Target): ProtonLink
- getRemoteSource(): Source
- getSource(): Source
- setSource(Source): ProtonLink
- getUnsettled(): int
- getQueued(): int
- advance(): boolean
- drained(): int
- detached(): boolean
- delivery(byte[], int, int): Delivery
- current(): Delivery
- setCondition(ErrorCondition): ProtonLink
- open(): ProtonLink
- close(): ProtonLink
- detach(): ProtonLink
- openHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
- closeHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
- detachHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
- isOpen(): boolean
- getQoS(): ProtonQoS
- getRemoteQoS(): ProtonQoS
- setQoS(ProtonQoS): ProtonLink
- getMaxMessageSize(): UnsignedLong
- setMaxMessageSize(UnsignedLong): void
- getRemoteMaxMessageSize(): UnsignedLong
- getRemoteProperties(): Map<Symbol, Object>
- setProperties(Map<Symbol, Object>): void
- setOfferedCapabilities(Symbol[]): void
- getRemoteOfferedCapabilities(): Symbol[]
- setDesiredCapabilities(Symbol[]): void
- getRemoteDesiredCapabilities(): Symbol[]
- free(): void
- fireRemoteOpen(): void
- fireRemoteDetach(): void
- fireRemoteClose(): void
- handleLinkFlow(): void
- ProtonMetaDataSupportImpl
-
ProtonReadableBufferImpl
- buffer: ByteBuf
- ProtonReadableBufferImpl(ByteBuf): void
- getBuffer(): ByteBuf
- capacity(): int
- hasArray(): boolean
- array(): byte[]
- arrayOffset(): int
- reclaimRead(): ReadableBuffer
- get(): byte
- get(int): byte
- getInt(): int
- getLong(): long
- getShort(): short
- getFloat(): float
- getDouble(): double
- get(byte[], int, int): ReadableBuffer
- get(byte[]): ReadableBuffer
- get(WritableBuffer): ReadableBuffer
- slice(): ReadableBuffer
- flip(): ReadableBuffer
- limit(int): ReadableBuffer
- limit(): int
- position(int): ReadableBuffer
- position(): int
- mark(): ReadableBuffer
- reset(): ReadableBuffer
- rewind(): ReadableBuffer
- clear(): ReadableBuffer
- remaining(): int
- hasRemaining(): boolean
- duplicate(): ReadableBuffer
- byteBuffer(): ByteBuffer
- readUTF8(): String
- readString(CharsetDecoder): String
-
ProtonReceiverImpl
- windowFullThreshhold: long
- recv(byte[], int, int): int
- LOG: Logger
- handler: ProtonMessageHandler
- prefetch: int
- drainCompleteHandler: Handler<AsyncResult<Void>>
- drainTimeoutTaskId: Long
- session: Session
- maxFrameSize: int
- sessionIncomingCapacity: long
- maxMessageSizeExceededHandler: Handler<ProtonReceiver>
- maxMessageSizeExceeded: boolean
- ProtonReceiverImpl(Receiver): void
- self(): ProtonReceiverImpl
- getReceiver(): Receiver
- getRemoteAddress(): String
- drain(long, Handler<AsyncResult<Void>>): ProtonReceiver
- setDrainHandlerAndTimeoutTask(long, Handler<AsyncResult<Void>>): void
- flow(int): ProtonReceiver
- flow(int, boolean): void
- draining(): boolean
- setDrain(boolean): ProtonReceiver
- handler(ProtonMessageHandler): ProtonReceiver
- maxMessageSizeExceededHandler(Handler<ProtonReceiver>): ProtonReceiver
- flushConnection(): void
- autoAccept: boolean
- splitContent: CompositeReadableBuffer
- onDelivery(): void
- checkMaxMessageSize(UnsignedLong, Delivery, Receiver): boolean
- handleMaxMessageSizeExceeded(UnsignedLong, Receiver): void
- handleDecodeFailure(Receiver, ProtonDeliveryImpl): void
- handleAborted(Receiver, Delivery): void
- handlePartial(Receiver, Delivery): void
- completePartial(ReadableBuffer): ReadableBuffer
- isAutoAccept(): boolean
- setAutoAccept(boolean): ProtonReceiver
- setPrefetch(int): ProtonReceiver
- getPrefetch(): int
- open(): ProtonReceiver
- handleLinkFlow(): void
- processForDrainCompletion(): void
-
ProtonSaslClientAuthenticatorImpl
- sasl: Sasl
- username: String
- password: String
- mechanism: ProtonSaslMechanism
- mechanismsRestriction: Set<String>
- handler: Handler<AsyncResult<ProtonConnection>>
- socket: NetSocket
- connection: ProtonConnection
- succeeded: boolean
- ProtonSaslClientAuthenticatorImpl(String, String, Set<String>, Handler<AsyncResult<ProtonConnection>>): void
- init(NetSocket, ProtonConnection, Transport): void
- process(Handler<Boolean>): void
- succeeded(): boolean
- handleSaslInit(): void
- handleSaslStep(): void
- handleSaslFail(): void
- ProtonSaslServerAuthenticatorImpl
-
ProtonSenderImpl
- drainHandler: Handler<ProtonSender>
- anonymousSender: boolean
- autoSettle: boolean
- tag: int
- autoDrained: boolean
- ProtonSenderImpl(Sender): void
- sender(): Sender
- send(Message): ProtonDelivery
- send(Message, Handler<ProtonDelivery>): ProtonDelivery
- generateTag(): byte[]
- setInt(byte[], int): void
- send(byte[], Message): ProtonDelivery
- send(byte[], Message, Handler<ProtonDelivery>): ProtonDelivery
- isAutoSettle(): boolean
- setAutoSettle(boolean): ProtonSender
- isAnonymousSender(): boolean
- setAnonymousSender(boolean): void
- self(): ProtonSenderImpl
- sendQueueFull(): boolean
- sendQueueDrainHandler(Handler<ProtonSender>): ProtonSender
- handleLinkFlow(): void
- isAutoDrained(): boolean
- setAutoDrained(boolean): ProtonSender
- drained(): int
- getRemoteAddress(): String
-
ProtonServerImpl
- vertx: Vertx
- server: NetServer
- handler: Handler<ProtonConnection>
- authenticatorFactory: ProtonSaslAuthenticatorFactory
- advertiseAnonymousRelayCapability: boolean
- options: ProtonServerOptions
- ProtonServerImpl(Vertx): void
- ProtonServerImpl(Vertx, ProtonServerOptions): void
- actualPort(): int
- listen(int): ProtonServerImpl
- listen(): ProtonServerImpl
- isMetricsEnabled(): boolean
- listen(int, String, Handler<AsyncResult<ProtonServer>>): ProtonServerImpl
- listen(Handler<AsyncResult<ProtonServer>>): ProtonServerImpl
- convertHandler(Handler<AsyncResult<ProtonServer>>): Handler<AsyncResult<NetServer>>
- listen(int, String): ProtonServerImpl
- listen(int, Handler<AsyncResult<ProtonServer>>): ProtonServerImpl
- close(): void
- close(Handler<AsyncResult<Void>>): void
- connectHandler(): Handler<ProtonConnection>
- saslAuthenticatorFactory(ProtonSaslAuthenticatorFactory): ProtonServer
- connectHandler(Handler<ProtonConnection>): ProtonServerImpl
- setAdvertiseAnonymousRelayCapability(boolean): void
- DefaultAuthenticatorFactory
-
ProtonSessionImpl
- LOG: Logger
- session: Session
- autoLinkCounter: int
- openHandler: Handler<AsyncResult<ProtonSession>>
- closeHandler: Handler<AsyncResult<ProtonSession>>
- ProtonSessionImpl(Session): void
- getConnection(): ProtonConnection
- getConnectionImpl(): ProtonConnectionImpl
- getOutgoingWindow(): long
- setIncomingCapacity(int): ProtonSession
- getOutgoingBytes(): int
- getRemoteState(): EndpointState
- getIncomingBytes(): int
- getRemoteCondition(): ErrorCondition
- getIncomingCapacity(): int
- getLocalState(): EndpointState
- setCondition(ErrorCondition): ProtonSession
- getCondition(): ErrorCondition
- setOutgoingWindow(long): void
- open(): ProtonSessionImpl
- close(): ProtonSessionImpl
- openHandler(Handler<AsyncResult<ProtonSession>>): ProtonSessionImpl
- closeHandler(Handler<AsyncResult<ProtonSession>>): ProtonSessionImpl
- generateLinkName(): String
- getOrCreateLinkName(ProtonLinkOptions): String
- createReceiver(String): ProtonReceiver
- createReceiver(String, ProtonLinkOptions): ProtonReceiver
- createSender(String): ProtonSender
- createSender(String, ProtonLinkOptions): ProtonSender
- attachments(): Record
- free(): void
- fireRemoteOpen(): void
- fireRemoteClose(): void
-
ProtonTransport
- LOG: Logger
- DEFAULT_MAX_FRAME_SIZE: int
- connection: Connection
- vertx: Vertx
- netClient: NetClient
- socket: NetSocket
- transport: Transport
- collector: Collector
- authenticator: ProtonSaslAuthenticator
- idleTimeoutCheckTimerId: Long
- failed: boolean
- ProtonTransport(Connection, Vertx, NetClient, NetSocket, ProtonSaslAuthenticator, ProtonTransportOptions): void
- handleSocketEnd(Void): void
- handleSocketBuffer(Buffer): void
- processSaslAuthentication(): void
- initiateIdleTimeoutChecks(): void
- cancelIdleTimeoutCheck(): void
- pumpInbound(Buffer): void
- flush(): void
- disconnect(): void
- IdleTimeoutCheck
-
ProtonWritableBufferImpl
- INITIAL_CAPACITY: int
- nettyBuffer: ByteBuf
- ProtonWritableBufferImpl(): void
- ProtonWritableBufferImpl(int): void
- ProtonWritableBufferImpl(ByteBuf): void
- getBuffer(): ByteBuf
- put(byte): void
- putFloat(float): void
- putDouble(double): void
- put(byte[], int, int): void
- put(ByteBuffer): void
- put(ByteBuf): void
- putShort(short): void
- putInt(int): void
- putLong(long): void
- hasRemaining(): boolean
- remaining(): int
- ensureRemaining(int): void
- position(): int
- position(int): void
- limit(): int
- put(ReadableBuffer): void
- put(String): void
-
ProtonClientImpl
- sasl
-
streams
- Delivery
- ProtonPublisher
-
ProtonPublisherOptions
- linkName: String
- durable: boolean
- shared: boolean
- global: boolean
- dynamic: boolean
- maxOutstandingCredit: int
- ProtonPublisherOptions(): void
- setLinkName(String): ProtonPublisherOptions
- getLinkName(): String
- setDurable(boolean): ProtonPublisherOptions
- isDurable(): boolean
- setShared(boolean): ProtonPublisherOptions
- isShared(): boolean
- setGlobal(boolean): ProtonPublisherOptions
- isGlobal(): boolean
- setDynamic(boolean): ProtonPublisherOptions
- isDynamic(): boolean
- setMaxOutstandingCredit(int): ProtonPublisherOptions
- getMaxOutstandingCredit(): int
- hashCode(): int
- equals(Object): boolean
-
ProtonStreams
- createDeliveryConsumer(ProtonConnection, String): ProtonPublisher<Delivery>
- createDeliveryConsumer(ProtonConnection, String, ProtonPublisherOptions): ProtonPublisher<Delivery>
- createConsumer(ProtonConnection, String): ProtonPublisher<Message>
- createConsumer(ProtonConnection, String, ProtonPublisherOptions): ProtonPublisher<Message>
- createTrackerProducer(ProtonConnection, String): ProtonSubscriber<Tracker>
- createTrackerProducer(ProtonConnection, String, ProtonSubscriberOptions): ProtonSubscriber<Tracker>
- createProducer(ProtonConnection, String): ProtonSubscriber<Message>
- createProducer(ProtonConnection, String, ProtonSubscriberOptions): ProtonSubscriber<Message>
- ProtonSubscriber
- ProtonSubscriberOptions
- Tracker
- impl
-
ProtonClient
-
proton
-
vertx