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.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- 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.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.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.1
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.mvel/mvel2/2.3.1.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
-
setTrustAll(boolean): ProtonClientOptions
-
enabledSaslMechanisms: Set<String>
-
heartbeat: int
-
maxFrameSize: int
-
virtualHost: String
-
sniServerName: String
-
ProtonClientOptions(): void
-
ProtonClientOptions(ProtonClientOptions): void
-
ProtonClientOptions(JsonObject): void
-
toJson(): JsonObject
-
getEnabledSaslMechanisms(): Set<String>
-
addEnabledSaslMechanism(String): ProtonClientOptions
-
setSendBufferSize(int): ProtonClientOptions
-
setReceiveBufferSize(int): ProtonClientOptions
-
setReuseAddress(boolean): ProtonClientOptions
-
setTrafficClass(int): ProtonClientOptions
-
setTcpNoDelay(boolean): ProtonClientOptions
-
setTcpKeepAlive(boolean): ProtonClientOptions
-
setSoLinger(int): ProtonClientOptions
-
setUsePooledBuffers(boolean): 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
-
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
-
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
-
attachments(): Record
-
getQoS(): ProtonQoS
-
open(): ProtonLink
-
close(): ProtonLink
-
detach(): ProtonLink
-
openHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
-
closeHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
-
detachHandler(Handler<AsyncResult<ProtonLink>>): ProtonLink
-
setQoS(ProtonQoS): ProtonLink
-
getRemoteQoS(): ProtonQoS
-
isOpen(): boolean
-
getTarget(): Target
-
setTarget(Target): ProtonLink
-
getRemoteTarget(): Target
-
getSource(): Source
-
setSource(Source): ProtonLink
-
getRemoteSource(): Source
-
getSession(): ProtonSession
-
getRemoteAddress(): String
-
setCondition(ErrorCondition): ProtonLink
-
getCondition(): ErrorCondition
-
getRemoteCondition(): ErrorCondition
-
getCredit(): int
-
getDrain(): boolean
-
getQueued(): int
-
getName(): String
-
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
-
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
-
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
-
setUsePooledBuffers(boolean): 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
-
setClientAuthRequired(boolean): 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
-
setOpenSslEngineOptions(OpenSSLEngineOptions): ProtonServerOptions
-
setSslEngineOptions(SSLEngineOptions): 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
-
createReceiver(String): ProtonReceiver
-
createReceiver(String, ProtonLinkOptions): ProtonReceiver
-
createSender(String): ProtonSender
-
createSender(String, ProtonLinkOptions): ProtonSender
-
open(): ProtonSession
-
close(): ProtonSession
-
attachments(): Record
-
setIncomingCapacity(int): ProtonSession
-
getIncomingCapacity(): int
-
getConnection(): ProtonConnection
-
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
-
getLink(): ProtonLinkImpl
-
clear(): void
-
delivery: Delivery
-
handler: Handler<ProtonDelivery>
-
autoSettle: boolean
-
ProtonDeliveryImpl(Delivery): 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
-
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
-
delivery(byte[]): Delivery
-
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
-
readUTF8(): String
-
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
-
readString(CharsetDecoder): String
-
-
ProtonReceiverImpl
-
getPrefetch(): int
-
LOG: Logger
-
handler: ProtonMessageHandler
-
prefetch: int
-
drainCompleteHandler: Handler<AsyncResult<Void>>
-
drainTimeoutTaskId: Long
-
session: Session
-
maxFrameSize: int
-
sessionIncomingCapacity: long
-
windowFullThreshhold: long
-
ProtonReceiverImpl(Receiver): void
-
self(): ProtonReceiverImpl
-
getReceiver(): Receiver
-
recv(byte[], int, int): int
-
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
-
flushConnection(): void
-
autoAccept: boolean
-
splitContent: CompositeReadableBuffer
-
onDelivery(): void
-
handleDecodeFailure(Receiver, ProtonDeliveryImpl): void
-
handleAborted(Receiver, Delivery): void
-
handlePartial(Receiver, Delivery): void
-
completePartial(ReadableBuffer): ReadableBuffer
-
isAutoAccept(): boolean
-
setAutoAccept(boolean): ProtonReceiver
-
setPrefetch(int): ProtonReceiver
-
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
-
close(): void
-
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(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
-
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
-
-
- 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
-
-
-
proton
-
vertx