Dependencies
- ant/ant/1.5.1 (available as org.apache.ant/ant/1.10.7)
- antlr/antlr/2.7.2
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- bsf/bsf/2.4.0 (available as org.apache.bsf/bsf-api/3.1)
- cglib/cglib-nodep/2.2 (available as cglib/cglib/3.3.0)
- com.beust/jcommander/1.47
- 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.jnr/jffi/1.2.18
- com.github.jnr/jffi/1.2.18/native
- com.github.jnr/jnr-constants/0.9.11
- com.github.jnr/jnr-enxio/0.19
- com.github.jnr/jnr-netdb/1.1.6
- com.github.jnr/jnr-posix/3.0.45
- com.github.jnr/jnr-unixsocket/0.20
- 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.headius/invokebinder/1.11
- com.headius/modulator/1.0
- com.headius/options/1.4
- com.jcraft/jsch/0.1.50
- com.jcraft/jsch.agentproxy.connector-factory/0.0.6
- com.jcraft/jsch.agentproxy.core/0.0.6
- com.jcraft/jsch.agentproxy.jsch/0.0.6
- com.jcraft/jsch.agentproxy.pageant/0.0.6
- com.jcraft/jsch.agentproxy.sshagent/0.0.6
- com.jcraft/jsch.agentproxy.usocket-jna/0.0.6
- com.jcraft/jsch.agentproxy.usocket-nc/0.0.6
- com.jcraft/jzlib/1.1.3
- com.martiansoftware/nailgun-server/0.9.1
- commons-codec/commons-codec/1.2
- commons-collections/commons-collections/3.1
- commons-httpclient/commons-httpclient/3.0
- commons-logging/commons-logging/1.2
- commons-net/commons-net/1.4.1
- commons-vfs/commons-vfs/1.0
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- com.thoughtworks.qdox/qdox/1.12.1
- com.thoughtworks.xstream/xstream/1.4.7
- dom4j/dom4j/1.6.1
- 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-auth-common/3.8.0
- io.vertx/vertx-bridge-common/3.8.0
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-codetrans/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- javax.servlet/servlet-api/2.5 (available as javax.servlet/javax.servlet-api/4.0.1)
- jaxen/jaxen/1.1-beta-6
- jaxme/jaxme-api/0.3
- jdom/jdom/1.0
- jline/jline/2.12
- joda-time/joda-time/2.9.9
- junit/junit/4.12
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- msv/relaxngDatatype/20030807
- msv/xsdlib/20030807
- net.java.dev.jna/jna/3.4.0
- net.java.dev.jna/platform/3.4.0
- net.jpountz.lz4/lz4/1.3.0
- net.sf.kxml/kxml2/2.3.0
- net.sf.kxml/kxml2-min/2.3.0
- org.apache.ant/ant/1.9.4
- org.apache.ant/ant-antlr/1.9.4
- org.apache.ant/ant-junit/1.9.4
- org.apache.ant/ant-launcher/1.9.4
- org.apache.ant/ant-nodeps/1.7.1
- org.apache.ant/ant-trax/1.7.1
- org.apache.felix/org.osgi.compendium/1.4.0
- org.apache.felix/org.osgi.core/1.4.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.ivy/ivy/2.4.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpg-jdk14/1.45
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk14/1.45
- org.bouncycastle/bcprov-jdk15on/1.54
- org.codehaus.gpars/gpars/1.2.1
- org.codehaus.groovy/groovy-all/2.4.7
- org.codehaus.jcsp/jcsp/1.1-rc5
- org.codehaus.jettison/jettison/1.2
- org.codehaus.jsr166-mirror/jsr166y/1.7.0
- org.codehaus.woodstox/wstx-asl/3.2.7
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.fusesource.jansi/jansi/1.11
- org.hamcrest/hamcrest-core/1.3
- org.jboss.logging/jboss-logging-spi/2.1.2.GA
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.jboss.netty/netty/3.2.9.Final
- org.jdom/jdom/1.1.3
- org.jdom/jdom2/2.0.5
- org.joda/joda-convert/1.2
- org.jruby/dirgra/0.3
- org.jruby.jcodings/jcodings/1.0.41
- org.jruby.joni/joni/2.1.25
- org.jruby/jruby-core/9.2.4.0
- org.jruby/jruby-stdlib/9.2.4.0
- org.json/json/20080701
- org.multiverse/multiverse-core/0.7.0
- org.mvel/mvel2/2.3.1.Final
- org.scala-lang/scala-library/2.12.0
- org.slf4j/slf4j-api/1.7.21
- org.testng/testng/6.8.13
- org.yaml/snakeyaml/1.12
- oro/oro/2.0.8
- pull-parser/pull-parser/2
- saxpath/saxpath/1.0-FCS
- stax/stax/1.2.0
- stax/stax-api/1.0.1
- xalan/serializer/2.7.1
- xalan/xalan/2.7.1
- xerces/xercesImpl/2.10.0
- xerces/xmlParserAPIs/2.6.2
- xml-apis/xml-apis/1.3.04
- xmlpull/xmlpull/1.1.3.1
- xml-resolver/xml-resolver/1.2
- xom/xom/1.1
- xpp3/xpp3/1.1.3.3
Declarations
-
examples
-
StompClientExamples
-
example1(Vertx): void
-
example2(Vertx): void
-
example21(Vertx): void
-
example3(Vertx): void
-
example4(Vertx): void
-
example5(Vertx): void
-
example6(Vertx): void
-
example7(Vertx, NetClient): void
-
example8(Vertx): void
-
example9(Vertx): void
-
example10(Vertx): void
-
example11(Vertx): void
-
example12(Vertx): void
-
example13(Vertx): void
-
example14(Vertx): void
-
-
StompServerExamples
-
example1(Vertx): void
-
example2(Vertx): void
-
example3(Vertx): void
-
example4(Vertx): void
-
example5(Vertx, NetServer): void
-
example6(Vertx): void
-
example7(Vertx, AuthProvider): void
-
example8(Vertx): void
-
example9(Vertx): void
-
example10(StompServer): void
-
example11(Vertx): void
-
example12(Vertx): void
-
example13(Vertx): void
-
example14(Vertx): void
-
example15(Vertx): void
-
example16(Vertx): void
-
example17(Vertx): void
-
example18(Vertx): void
-
-
-
io
-
vertx
-
ext
-
stomp
-
Acknowledgement
-
BridgeOptions
-
DEFAULT_POINT_TO_POINT: boolean
-
pointToPoint: boolean
-
BridgeOptions(): void
-
BridgeOptions(BridgeOptions): void
-
BridgeOptions(JsonObject): void
-
toJson(): JsonObject
-
setPointToPoint(boolean): BridgeOptions
-
isPointToPoint(): boolean
-
setInboundPermitteds(List<PermittedOptions>): BridgeOptions
-
setOutboundPermitteds(List<PermittedOptions>): BridgeOptions
-
addInboundPermitted(PermittedOptions): BridgeOptions
-
addOutboundPermitted(PermittedOptions): BridgeOptions
-
-
DefaultAbortHandler
-
DefaultAckHandler
-
DefaultBeginHandler
-
DefaultCommitHandler
-
DefaultConnectHandler
-
DefaultNackHandler
-
DefaultSendHandler
-
DefaultSubscribeHandler
-
DefaultUnsubscribeHandler
-
Destination
-
topic(Vertx, String): Destination
-
queue(Vertx, String): Destination
-
bridge(Vertx, BridgeOptions): Destination
-
destination(): String
-
dispatch(StompServerConnection, Frame): Destination
-
subscribe(StompServerConnection, Frame): Destination
-
unsubscribe(StompServerConnection, Frame): boolean
-
unsubscribeConnection(StompServerConnection): Destination
-
ack(StompServerConnection, Frame): boolean
-
nack(StompServerConnection, Frame): boolean
-
getSubscriptions(StompServerConnection): List<String>
-
numberOfSubscriptions(): int
-
matches(String): boolean
-
-
DestinationFactory
-
Frame
-
TRANSACTION: String
-
MESSAGE: String
-
ID: String
-
SUBSCRIPTION: String
-
MESSAGE_ID: String
-
CONTENT_LENGTH: String
-
CONTENT_TYPE: String
-
HOST: String
-
VERSION: String
-
ACCEPT_VERSION: String
-
SESSION: String
-
SERVER: String
-
LOGIN: String
-
PASSCODE: String
-
HEARTBEAT: String
-
DESTINATION: String
-
RECEIPT: String
-
RECEIPT_ID: String
-
ACK: String
-
STOMP_FRAME_COMMAND: String
-
CHARSET_PATTERN: Pattern
-
Command
-
Heartbeat
-
COMMANDS_ACCEPTING_BODY: List<Command>
-
command: Command
-
headers: Map<String, String>
-
body: Buffer
-
Frame(): void
-
Frame(Frame): void
-
Frame(JsonObject): void
-
Frame(Command, Map<String, String>, Buffer): void
-
addHeader(String, String): Frame
-
getAck(): String
-
getHeaders(): Map<String, String>
-
setHeaders(Map<String, String>): Frame
-
setCommand(Command): Frame
-
setBody(Buffer): Frame
-
toJson(): JsonObject
-
validate(): void
-
hasEmptyBody(): boolean
-
getCommand(): Command
-
getHeader(String): String
-
getBody(): Buffer
-
getBodyAsString(String): String
-
getBodyAsString(): String
-
encoding(): String
-
getBodyAsByteArray(): byte[]
-
toBuffer(boolean): Buffer
-
toBuffer(): Buffer
-
encode(String): String
-
toString(): String
-
setDestination(String): Frame
-
setTransaction(String): Frame
-
setId(String): Frame
-
getId(): String
-
getReceipt(): String
-
getTransaction(): String
-
getDestination(): String
-
-
FrameConverter
-
Frames
-
ServerFrame
-
StompClient
-
create(Vertx): StompClient
-
create(Vertx, StompClientOptions): StompClient
-
connect(int, String, Handler<AsyncResult<StompClientConnection>>): StompClient
-
connect(NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
-
connect(int, String, NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
-
connect(Handler<AsyncResult<StompClientConnection>>): StompClient
-
receivedFrameHandler(Handler<Frame>): StompClient
-
writingFrameHandler(Handler<Frame>): StompClient
-
errorFrameHandler(Handler<Frame>): StompClient
-
exceptionHandler(Handler<Throwable>): StompClient
-
close(): void
-
options(): StompClientOptions
-
vertx(): Vertx
-
isClosed(): boolean
-
-
StompClientConnection
-
session(): String
-
version(): String
-
close(): void
-
server(): String
-
send(Map<String, String>, Buffer): StompClientConnection
-
send(Map<String, String>, Buffer, Handler<Frame>): StompClientConnection
-
send(String, Buffer): StompClientConnection
-
send(String, Buffer, Handler<Frame>): StompClientConnection
-
send(Frame): StompClientConnection
-
send(Frame, Handler<Frame>): StompClientConnection
-
send(String, Map<String, String>, Buffer): StompClientConnection
-
send(String, Map<String, String>, Buffer, Handler<Frame>): StompClientConnection
-
subscribe(String, Handler<Frame>): String
-
subscribe(String, Handler<Frame>, Handler<Frame>): String
-
subscribe(String, Map<String, String>, Handler<Frame>): String
-
subscribe(String, Map<String, String>, Handler<Frame>, Handler<Frame>): String
-
unsubscribe(String): StompClientConnection
-
unsubscribe(String, Handler<Frame>): StompClientConnection
-
unsubscribe(String, Map<String, String>): StompClientConnection
-
unsubscribe(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
errorHandler(Handler<Frame>): StompClientConnection
-
closeHandler(Handler<StompClientConnection>): StompClientConnection
-
connectionDroppedHandler(Handler<StompClientConnection>): StompClientConnection
-
pingHandler(Handler<StompClientConnection>): StompClientConnection
-
beginTX(String, Handler<Frame>): StompClientConnection
-
beginTX(String): StompClientConnection
-
beginTX(String, Map<String, String>): StompClientConnection
-
beginTX(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
commit(String): StompClientConnection
-
commit(String, Handler<Frame>): StompClientConnection
-
commit(String, Map<String, String>): StompClientConnection
-
commit(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
abort(String): StompClientConnection
-
abort(String, Handler<Frame>): StompClientConnection
-
abort(String, Map<String, String>): StompClientConnection
-
abort(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
disconnect(): StompClientConnection
-
disconnect(Handler<Frame>): StompClientConnection
-
disconnect(Frame): StompClientConnection
-
disconnect(Frame, Handler<Frame>): StompClientConnection
-
ack(String): StompClientConnection
-
ack(String, Handler<Frame>): StompClientConnection
-
nack(String): StompClientConnection
-
nack(String, Handler<Frame>): StompClientConnection
-
ack(String, String): StompClientConnection
-
ack(String, String, Handler<Frame>): StompClientConnection
-
nack(String, String): StompClientConnection
-
nack(String, String, Handler<Frame>): StompClientConnection
-
receivedFrameHandler(Handler<Frame>): StompClientConnection
-
writingFrameHandler(Handler<Frame>): StompClientConnection
-
exceptionHandler(Handler<Throwable>): StompClientConnection
-
isConnected(): boolean
-
-
StompClientOptions
-
DEFAULT_CLIENT_REUSE_ADDRESS: boolean
-
acceptedVersions: List<String>
-
port: int
-
host: String
-
login: String
-
passcode: String
-
autoComputeContentLength: boolean
-
useStompFrame: boolean
-
bypassHostHeader: boolean
-
heartbeat: JsonObject
-
virtualHost: String
-
trailingLine: boolean
-
StompClientOptions(): void
-
StompClientOptions(StompClientOptions): void
-
StompClientOptions(JsonObject): void
-
init(): void
-
toJson(): JsonObject
-
getHost(): String
-
setHost(String): StompClientOptions
-
getLogin(): String
-
setLogin(String): StompClientOptions
-
getPasscode(): String
-
setPasscode(String): StompClientOptions
-
getPort(): int
-
setPort(int): StompClientOptions
-
getAcceptedVersions(): List<String>
-
setAcceptedVersions(List<String>): StompClientOptions
-
isAutoComputeContentLength(): boolean
-
setAutoComputeContentLength(boolean): StompClientOptions
-
isUseStompFrame(): boolean
-
setUseStompFrame(boolean): StompClientOptions
-
setSsl(boolean): StompClientOptions
-
isBypassHostHeader(): boolean
-
setBypassHostHeader(boolean): StompClientOptions
-
getHeartbeat(): JsonObject
-
setHeartbeat(JsonObject): StompClientOptions
-
getVirtualHost(): String
-
setVirtualHost(String): StompClientOptions
-
isTrailingLine(): boolean
-
setTrailingLine(boolean): StompClientOptions
-
-
StompClientOptionsConverter
-
StompOptions
-
StompServer
-
create(Vertx, StompServerOptions): StompServer
-
create(Vertx, NetServer): StompServer
-
create(Vertx, NetServer, StompServerOptions): StompServer
-
create(Vertx): StompServer
-
handler(StompServerHandler): StompServer
-
listen(int): StompServer
-
listen(int, String): StompServer
-
listen(): StompServer
-
listen(Handler<AsyncResult<StompServer>>): StompServer
-
listen(int, Handler<AsyncResult<StompServer>>): StompServer
-
listen(int, String, Handler<AsyncResult<StompServer>>): StompServer
-
close(Handler<AsyncResult<Void>>): void
-
close(): void
-
isListening(): boolean
-
actualPort(): int
-
options(): StompServerOptions
-
vertx(): Vertx
-
stompHandler(): StompServerHandler
-
webSocketHandler(): Handler<ServerWebSocket>
-
writingFrameHandler(Handler<ServerFrame>): StompServer
-
-
StompServerConnection
-
StompServerHandler
-
create(Vertx): StompServerHandler
-
receivedFrameHandler(Handler<ServerFrame>): StompServerHandler
-
connectHandler(Handler<ServerFrame>): StompServerHandler
-
stompHandler(Handler<ServerFrame>): StompServerHandler
-
subscribeHandler(Handler<ServerFrame>): StompServerHandler
-
unsubscribeHandler(Handler<ServerFrame>): StompServerHandler
-
sendHandler(Handler<ServerFrame>): StompServerHandler
-
closeHandler(Handler<StompServerConnection>): StompServerHandler
-
onClose(StompServerConnection): void
-
commitHandler(Handler<ServerFrame>): StompServerHandler
-
abortHandler(Handler<ServerFrame>): StompServerHandler
-
beginHandler(Handler<ServerFrame>): StompServerHandler
-
disconnectHandler(Handler<ServerFrame>): StompServerHandler
-
ackHandler(Handler<ServerFrame>): StompServerHandler
-
nackHandler(Handler<ServerFrame>): StompServerHandler
-
onAuthenticationRequest(StompServerConnection, String, String, Handler<AsyncResult<Boolean>>): StompServerHandler
-
getUserBySession(String): User
-
authProvider(AuthProvider): StompServerHandler
-
getDestinations(): List<Destination>
-
getDestination(String): Destination
-
onAck(StompServerConnection, Frame, List<Frame>): StompServerHandler
-
onNack(StompServerConnection, Frame, List<Frame>): StompServerHandler
-
onAckHandler(Handler<Acknowledgement>): StompServerHandler
-
onNackHandler(Handler<Acknowledgement>): StompServerHandler
-
pingHandler(Handler<StompServerConnection>): StompServerHandler
-
getOrCreateDestination(String): Destination
-
destinationFactory(DestinationFactory): StompServerHandler
-
bridge(BridgeOptions): StompServerHandler
-
-
StompServerOptions
-
DEFAULT_MAX_BODY_LENGTH: int
-
DEFAULT_MAX_HEADER_LENGTH: int
-
DEFAULT_MAX_HEADERS: int
-
DEFAULT_MAX_FRAME_IN_TRANSACTION: int
-
DEFAULT_TRANSACTION_CHUNK_SIZE: int
-
DEFAULT_MAX_SUBSCRIPTIONS_BY_CLIENT: int
-
DEFAULT_WEBSOCKET_PATH: String
-
maxHeaderLength: int
-
maxHeaders: int
-
maxBodyLength: int
-
maxFrameInTransaction: int
-
supportedVersions: List<String>
-
secured: boolean
-
sendErrorOnNoSubscriptions: boolean
-
ackTimeout: long
-
timeFactor: int
-
heartbeat: JsonObject
-
transactionChunkSize: int
-
maxSubscriptionsByClient: int
-
websocketBridge: boolean
-
websocketPath: String
-
disableTCPServer: boolean
-
trailingLine: boolean
-
StompServerOptions(): void
-
StompServerOptions(StompServerOptions): void
-
StompServerOptions(JsonObject): void
-
toJson(): JsonObject
-
getMaxBodyLength(): int
-
setMaxBodyLength(int): StompServerOptions
-
getMaxHeaderLength(): int
-
setMaxHeaderLength(int): StompServerOptions
-
getMaxHeaders(): int
-
setMaxHeaders(int): StompServerOptions
-
getSupportedVersions(): List<String>
-
setSupportedVersions(List<String>): StompServerOptions
-
isSecured(): boolean
-
setSecured(boolean): StompServerOptions
-
isSendErrorOnNoSubscriptions(): boolean
-
setSendErrorOnNoSubscriptions(boolean): StompServerOptions
-
getTimeFactor(): int
-
setTimeFactor(int): StompServerOptions
-
setSsl(boolean): StompServerOptions
-
setPort(int): StompServerOptions
-
getPort(): int
-
setHost(String): StompServerOptions
-
getHeartbeat(): JsonObject
-
setHeartbeat(JsonObject): StompServerOptions
-
getMaxFrameInTransaction(): int
-
setMaxFrameInTransaction(int): StompServerOptions
-
getTransactionChunkSize(): int
-
setTransactionChunkSize(int): StompServerOptions
-
getMaxSubscriptionsByClient(): int
-
setMaxSubscriptionsByClient(int): StompServerOptions
-
isWebsocketBridge(): boolean
-
setWebsocketBridge(boolean): StompServerOptions
-
getWebsocketPath(): String
-
setWebsocketPath(String): StompServerOptions
-
isTrailingLine(): boolean
-
setTrailingLine(boolean): StompServerOptions
-
-
StompServerOptionsConverter
-
impl
-
AcknowledgementImpl
-
DefaultStompHandler
-
LOGGER: Logger
-
vertx: Vertx
-
context: Context
-
connectHandler: Handler<ServerFrame>
-
stompHandler: Handler<ServerFrame>
-
sendHandler: Handler<ServerFrame>
-
subscribeHandler: Handler<ServerFrame>
-
unsubscribeHandler: Handler<ServerFrame>
-
closeHandler: Handler<StompServerConnection>
-
commitHandler: Handler<ServerFrame>
-
abortHandler: Handler<ServerFrame>
-
beginHandler: Handler<ServerFrame>
-
ackHandler: Handler<ServerFrame>
-
nackHandler: Handler<ServerFrame>
-
disconnectHandler: Handler<ServerFrame>
-
authProvider: AuthProvider
-
pingHandler: Handler<StompServerConnection>
-
onAckHandler: Handler<Acknowledgement>
-
onNackHandler: Handler<Acknowledgement>
-
destinations: LocalMap<Destination, String>
-
users: ConcurrentHashMap<String, User>
-
factory: DestinationFactory
-
receivedFrameHandler: Handler<ServerFrame>
-
DefaultStompHandler(Vertx): void
-
onClose(StompServerConnection): void
-
receivedFrameHandler(Handler<ServerFrame>): StompServerHandler
-
connectHandler(Handler<ServerFrame>): StompServerHandler
-
stompHandler(Handler<ServerFrame>): StompServerHandler
-
subscribeHandler(Handler<ServerFrame>): StompServerHandler
-
unsubscribeHandler(Handler<ServerFrame>): StompServerHandler
-
sendHandler(Handler<ServerFrame>): StompServerHandler
-
closeHandler(Handler<StompServerConnection>): StompServerHandler
-
commitHandler(Handler<ServerFrame>): StompServerHandler
-
abortHandler(Handler<ServerFrame>): StompServerHandler
-
beginHandler(Handler<ServerFrame>): StompServerHandler
-
disconnectHandler(Handler<ServerFrame>): StompServerHandler
-
ackHandler(Handler<ServerFrame>): StompServerHandler
-
nackHandler(Handler<ServerFrame>): StompServerHandler
-
handle(ServerFrame): void
-
handleAck(Frame, StompServerConnection): void
-
handleNack(Frame, StompServerConnection): void
-
handleBegin(Frame, StompServerConnection): void
-
handleAbort(Frame, StompServerConnection): void
-
handleCommit(Frame, StompServerConnection): void
-
handleSubscribe(Frame, StompServerConnection): void
-
handleUnsubscribe(Frame, StompServerConnection): void
-
handleSend(Frame, StompServerConnection): void
-
handleConnect(Frame, StompServerConnection): void
-
handleDisconnect(Frame, StompServerConnection): void
-
handleStomp(Frame, StompServerConnection): void
-
authProvider(AuthProvider): StompServerHandler
-
onAuthenticationRequest(StompServerConnection, String, String, Handler<AsyncResult<Boolean>>): StompServerHandler
-
getUserBySession(String): User
-
getDestinations(): List<Destination>
-
getDestination(String): Destination
-
getOrCreateDestination(String): Destination
-
destinationFactory(DestinationFactory): StompServerHandler
-
bridge(BridgeOptions): StompServerHandler
-
onAck(StompServerConnection, Frame, List<Frame>): StompServerHandler
-
onNack(StompServerConnection, Frame, List<Frame>): StompServerHandler
-
onAckHandler(Handler<Acknowledgement>): StompServerHandler
-
onNackHandler(Handler<Acknowledgement>): StompServerHandler
-
pingHandler(Handler<StompServerConnection>): StompServerHandler
-
-
EventBusBridge
-
options: BridgeOptions
-
expressions: Map<String, Pattern>
-
registry: Map<String, MessageConsumer<Object>>
-
EventBusBridge(Vertx, BridgeOptions): void
-
destination(): String
-
subscribe(StompServerConnection, Frame): Destination
-
unsubscribe(StompServerConnection, Frame): boolean
-
unsubscribeConnection(StompServerConnection): Destination
-
transform(Message<Object>, Subscription): Frame
-
dispatch(StompServerConnection, Frame): Destination
-
send(String, Frame, Handler<AsyncResult<Message<Object>>>): void
-
toMultimap(Map<String, String>): MultiMap
-
matches(String, Buffer): boolean
-
matches(String): boolean
-
regexMatches(String, String): boolean
-
checkMatches(boolean, String, Object): boolean
-
structureMatches(JsonObject, Object): boolean
-
-
FrameException
-
FrameParser
-
FrameParser(): void
-
FrameParser(StompServerOptions): void
-
NULL: String
-
EOL: String
-
CARRIAGE_RETURN: String
-
LINE_FEED: char
-
COLON: String
-
ESCAPE: char
-
COMMA: String
-
options: StompServerOptions
-
command: Command
-
headers: HashMap<String, String>
-
handler: Handler<Frame>
-
bodyLength: int
-
errorHandler: Handler<FrameException>
-
State
-
frameParser: RecordParser
-
current: State
-
handler(Handler<Frame>): FrameParser
-
errorHandler(Handler<FrameException>): FrameParser
-
handleLine(Buffer): void
-
reset(): void
-
hasExceededHeaderLength(String, String): boolean
-
hasExceededNumberOfHeaders(): boolean
-
decode(String): String
-
strip(String): String
-
isEmpty(Buffer): boolean
-
handle(Buffer): void
-
hasExceededBodySize(): boolean
-
reportOrThrow(String): void
-
-
HeaderCodec
-
Queue
-
destination: String
-
subscriptions: List<Subscription>
-
vertx: Vertx
-
lastUsedSubscriptions: int
-
Queue(Vertx, String): void
-
destination(): String
-
dispatch(StompServerConnection, Frame): Destination
-
getNextSubscription(): Subscription
-
transform(Frame, Subscription, String): Frame
-
subscribe(StompServerConnection, Frame): Destination
-
unsubscribe(StompServerConnection, Frame): boolean
-
unsubscribeConnection(StompServerConnection): Destination
-
ack(StompServerConnection, Frame): boolean
-
nack(StompServerConnection, Frame): boolean
-
getSubscriptions(StompServerConnection): List<String>
-
numberOfSubscriptions(): int
-
matches(String): boolean
-
Subscription
-
-
ServerFrameImpl
-
StompClientConnectionImpl
-
LOGGER: Logger
-
client: StompClient
-
socket: NetSocket
-
resultHandler: Handler<AsyncResult<StompClientConnection>>
-
context: Context
-
lastServerActivity: long
-
pendingReceipts: Map<String, Handler<Void>>
-
version: String
-
sessionId: String
-
server: String
-
subscriptions: List<Subscription>
-
pinger: long
-
ponger: long
-
pingHandler: Handler<StompClientConnection>
-
closeHandler: Handler<StompClientConnection>
-
droppedHandler: Handler<StompClientConnection>
-
receivedFrameHandler: Handler<Frame>
-
writingHandler: Handler<Frame>
-
errorHandler: Handler<Frame>
-
closed: boolean
-
exceptionHandler: Handler<Throwable>
-
connected: boolean
-
Subscription
-
StompClientConnectionImpl(Vertx, NetSocket, StompClient, Handler<AsyncResult<StompClientConnection>>): void
-
isConnected(): boolean
-
session(): String
-
version(): String
-
close(): void
-
server(): String
-
send(Map<String, String>, Buffer): StompClientConnection
-
send(Map<String, String>, Buffer, Handler<Frame>): StompClientConnection
-
send(String, Buffer): StompClientConnection
-
send(String, Buffer, Handler<Frame>): StompClientConnection
-
send(Frame): StompClientConnection
-
send(Frame, Handler<Frame>): StompClientConnection
-
send(String, Map<String, String>, Buffer): StompClientConnection
-
abort(String): StompClientConnection
-
send(String, Map<String, String>, Buffer, Handler<Frame>): StompClientConnection
-
subscribe(String, Handler<Frame>): String
-
subscribe(String, Handler<Frame>, Handler<Frame>): String
-
subscribe(String, Map<String, String>, Handler<Frame>): String
-
subscribe(String, Map<String, String>, Handler<Frame>, Handler<Frame>): String
-
unsubscribe(String): StompClientConnection
-
unsubscribe(String, Handler<Frame>): StompClientConnection
-
unsubscribe(String, Map<String, String>): StompClientConnection
-
unsubscribe(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
errorHandler(Handler<Frame>): StompClientConnection
-
closeHandler(Handler<StompClientConnection>): StompClientConnection
-
pingHandler(Handler<StompClientConnection>): StompClientConnection
-
beginTX(String, Handler<Frame>): StompClientConnection
-
beginTX(String): StompClientConnection
-
beginTX(String, Map<String, String>): StompClientConnection
-
beginTX(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
commit(String): StompClientConnection
-
commit(String, Handler<Frame>): StompClientConnection
-
commit(String, Map<String, String>): StompClientConnection
-
commit(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
abort(String, Handler<Frame>): StompClientConnection
-
abort(String, Map<String, String>): StompClientConnection
-
abort(String, Map<String, String>, Handler<Frame>): StompClientConnection
-
disconnect(): StompClientConnection
-
disconnect(Frame): StompClientConnection
-
disconnect(Handler<Frame>): StompClientConnection
-
disconnect(Frame, Handler<Frame>): StompClientConnection
-
ack(String): StompClientConnection
-
ack(String, Handler<Frame>): StompClientConnection
-
nack(String): StompClientConnection
-
nack(String, Handler<Frame>): StompClientConnection
-
ack(String, String): StompClientConnection
-
ack(String, String, Handler<Frame>): StompClientConnection
-
nack(String, String): StompClientConnection
-
nack(String, String, Handler<Frame>): StompClientConnection
-
receivedFrameHandler(Handler<Frame>): StompClientConnection
-
writingFrameHandler(Handler<Frame>): StompClientConnection
-
exceptionHandler(Handler<Throwable>): StompClientConnection
-
connectionDroppedHandler(Handler<StompClientConnection>): StompClientConnection
-
handle(Frame): void
-
handleReceipt(Frame): void
-
handleConnected(Frame): void
-
socket(): NetSocket
-
-
StompClientImpl
-
log: Logger
-
vertx: Vertx
-
options: StompClientOptions
-
client: NetClient
-
receivedFrameHandler: Handler<Frame>
-
writingFrameHandler: Handler<Frame>
-
errorFrameHandler: Handler<Frame>
-
exceptionHandler: Handler<Throwable>
-
StompClientImpl(Vertx, StompClientOptions): void
-
connect(int, String, Handler<AsyncResult<StompClientConnection>>): StompClient
-
connect(Handler<AsyncResult<StompClientConnection>>): StompClient
-
receivedFrameHandler(Handler<Frame>): StompClient
-
writingFrameHandler(Handler<Frame>): StompClient
-
errorFrameHandler(Handler<Frame>): StompClient
-
exceptionHandler(Handler<Throwable>): StompClient
-
connect(NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
-
close(): void
-
options(): StompClientOptions
-
vertx(): Vertx
-
isClosed(): boolean
-
connect(int, String, NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
-
getConnectFrame(String): Frame
-
getAcceptedVersions(): String
-
-
StompServerImpl
-
LOGGER: Logger
-
vertx: Vertx
-
options: StompServerOptions
-
server: NetServer
-
handler: StompServerHandler
-
listening: boolean
-
writingFrameHandler: Handler<ServerFrame>
-
StompServerImpl(Vertx, NetServer, StompServerOptions): void
-
handler(StompServerHandler): StompServer
-
listen(): StompServer
-
listen(Handler<AsyncResult<StompServer>>): StompServer
-
listen(int): StompServer
-
listen(int, String): StompServer
-
listen(int, Handler<AsyncResult<StompServer>>): StompServer
-
listen(int, String, Handler<AsyncResult<StompServer>>): StompServer
-
close(): void
-
isListening(): boolean
-
actualPort(): int
-
options(): StompServerOptions
-
vertx(): Vertx
-
stompHandler(): StompServerHandler
-
close(Handler<AsyncResult<Void>>): void
-
webSocketHandler(): Handler<ServerWebSocket>
-
writingFrameHandler(Handler<ServerFrame>): StompServer
-
-
StompServerTCPConnectionImpl
-
log: Logger
-
server: StompServer
-
socket: NetSocket
-
sessionId: String
-
handler: Handler<ServerFrame>
-
lastClientActivity: long
-
pinger: long
-
ponger: long
-
StompServerTCPConnectionImpl(NetSocket, StompServer, Handler<ServerFrame>): void
-
StompServerTCPConnectionImpl(StompServer, Handler<ServerFrame>): void
-
write(Frame): StompServerConnection
-
write(Buffer): StompServerConnection
-
server(): StompServer
-
handler(): StompServerHandler
-
session(): String
-
close(): void
-
ping(): void
-
cancelHeartbeat(): void
-
onServerActivity(): void
-
configureHeartbeat(long, long, Handler<StompServerConnection>): void
-
-
StompServerWebSocketConnectionImpl
-
Topic
-
destination: String
-
subscriptions: List<Subscription>
-
vertx: Vertx
-
Topic(Vertx, String): void
-
destination(): String
-
dispatch(StompServerConnection, Frame): Destination
-
transform(Frame, Subscription, String): Frame
-
subscribe(StompServerConnection, Frame): Destination
-
unsubscribe(StompServerConnection, Frame): boolean
-
unsubscribeConnection(StompServerConnection): Destination
-
ack(StompServerConnection, Frame): boolean
-
nack(StompServerConnection, Frame): boolean
-
getSubscriptions(StompServerConnection): List<String>
-
numberOfSubscriptions(): int
-
matches(String): boolean
-
Subscription
-
-
Transaction
-
Transactions
-
INSTANCE: Transactions
-
transactions: List<Transaction>
-
instance(): Transactions
-
Transactions(): void
-
getTransaction(StompServerConnection, String): Transaction
-
registerTransaction(StompServerConnection, String): boolean
-
unregisterTransaction(StompServerConnection, String): boolean
-
unregisterTransactionsFromConnection(StompServerConnection): void
-
getTransactionCount(): int
-
-
- utils
-
-
stomp
-
ext
-
vertx