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.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/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
- 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.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-auth-common/4.0.0
- io.vertx/vertx-bridge-common/4.0.0
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-codetrans/4.0.0
- io.vertx/vertx-core/4.0.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/1.6
- 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.65
- org.bouncycastle/bcprov-jdk14/1.45
- org.bouncycastle/bcprov-jdk15on/1.65
- 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.json/json/20080701
- org.multiverse/multiverse-core/0.7.0
- 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, AuthenticationProvider): 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
-
StompClientExamples
-
io
-
vertx
-
ext
-
stomp
- Acknowledgement
-
BridgeOptions
- setPointToPoint(boolean): BridgeOptions
- isPointToPoint(): boolean
- toJson(): JsonObject
- DEFAULT_POINT_TO_POINT: boolean
- pointToPoint: boolean
- BridgeOptions(): void
- BridgeOptions(BridgeOptions): void
- BridgeOptions(JsonObject): void
- 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
- Heartbeat
- getTransaction(): String
- getDestination(): 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
- ID: String
- SUBSCRIPTION: String
- MESSAGE_ID: String
- TRANSACTION: String
- MESSAGE: String
- STOMP_FRAME_COMMAND: String
- CHARSET_PATTERN: Pattern
- Command
- 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
- FrameConverter
- Frames
- ServerFrame
-
StompClient
- create(Vertx): StompClient
- create(Vertx, StompClientOptions): StompClient
- connect(int, String, Handler<AsyncResult<StompClientConnection>>): StompClient
- connect(int, String): Future<StompClientConnection>
- connect(NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
- connect(NetClient): Future<StompClientConnection>
- connect(int, String, NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
- connect(int, String, NetClient): Future<StompClientConnection>
- connect(Handler<AsyncResult<StompClientConnection>>): StompClient
- connect(): Future<StompClientConnection>
- 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): Future<Frame>
- send(Map<String, String>, Buffer, Handler<AsyncResult<Frame>>): StompClientConnection
- send(String, Buffer): Future<Frame>
- send(String, Buffer, Handler<AsyncResult<Frame>>): StompClientConnection
- send(Frame): Future<Frame>
- send(Frame, Handler<AsyncResult<Frame>>): StompClientConnection
- send(String, Map<String, String>, Buffer): Future<Frame>
- send(String, Map<String, String>, Buffer, Handler<AsyncResult<Frame>>): StompClientConnection
- subscribe(String, Handler<Frame>): Future<String>
- subscribe(String, Handler<Frame>, Handler<AsyncResult<String>>): StompClientConnection
- subscribe(String, Map<String, String>, Handler<Frame>): Future<String>
- subscribe(String, Map<String, String>, Handler<Frame>, Handler<AsyncResult<String>>): StompClientConnection
- unsubscribe(String): Future<Frame>
- unsubscribe(String, Handler<AsyncResult<Frame>>): StompClientConnection
- unsubscribe(String, Map<String, String>): Future<Frame>
- unsubscribe(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- errorHandler(Handler<Frame>): StompClientConnection
- closeHandler(Handler<StompClientConnection>): StompClientConnection
- connectionDroppedHandler(Handler<StompClientConnection>): StompClientConnection
- pingHandler(Handler<StompClientConnection>): StompClientConnection
- beginTX(String, Handler<AsyncResult<Frame>>): StompClientConnection
- beginTX(String): Future<Frame>
- beginTX(String, Map<String, String>): Future<Frame>
- beginTX(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- commit(String): Future<Frame>
- commit(String, Handler<AsyncResult<Frame>>): StompClientConnection
- commit(String, Map<String, String>): Future<Frame>
- commit(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- abort(String): Future<Frame>
- abort(String, Handler<AsyncResult<Frame>>): StompClientConnection
- abort(String, Map<String, String>): Future<Frame>
- abort(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- disconnect(): Future<Frame>
- disconnect(Handler<AsyncResult<Frame>>): StompClientConnection
- disconnect(Frame): Future<Frame>
- disconnect(Frame, Handler<AsyncResult<Frame>>): StompClientConnection
- ack(String): Future<Frame>
- ack(String, Handler<AsyncResult<Frame>>): StompClientConnection
- nack(String): Future<Frame>
- nack(String, Handler<AsyncResult<Frame>>): StompClientConnection
- ack(String, String): Future<Frame>
- ack(String, String, Handler<AsyncResult<Frame>>): StompClientConnection
- nack(String, String): Future<Frame>
- nack(String, String, Handler<AsyncResult<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): Future<StompServer>
- listen(int, String): Future<StompServer>
- listen(): Future<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(): Future<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
- onAuthenticationRequest(StompServerConnection, String, String): Future<Boolean>
- getUserBySession(String): User
- authProvider(AuthenticationProvider): 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_HEADER_LENGTH: int
- DEFAULT_MAX_HEADERS: int
- DEFAULT_MAX_BODY_LENGTH: 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: AuthenticationProvider
- 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(AuthenticationProvider): StompServerHandler
- onAuthenticationRequest(StompServerConnection, String, String): Future<Boolean>
- 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
- 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
- FrameParser(StompServerOptions): void
- FrameParser(): void
- 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, Promise<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): Future<Frame>
- send(Map<String, String>, Buffer, Handler<AsyncResult<Frame>>): StompClientConnection
- send(String, Buffer): Future<Frame>
- send(String, Buffer, Handler<AsyncResult<Frame>>): StompClientConnection
- send(Frame): Future<Frame>
- send(Frame, Handler<AsyncResult<Frame>>): StompClientConnection
- send(String, Map<String, String>, Buffer): Future<Frame>
- send(String, Map<String, String>, Buffer, Handler<AsyncResult<Frame>>): StompClientConnection
- subscribe(String, Handler<Frame>): Future<String>
- subscribe(String, Handler<Frame>, Handler<AsyncResult<String>>): StompClientConnection
- subscribe(String, Map<String, String>, Handler<Frame>): Future<String>
- subscribe(String, Map<String, String>, Handler<Frame>, Handler<AsyncResult<String>>): StompClientConnection
- unsubscribe(String): Future<Frame>
- unsubscribe(String, Handler<AsyncResult<Frame>>): StompClientConnection
- unsubscribe(String, Map<String, String>): Future<Frame>
- unsubscribe(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- errorHandler(Handler<Frame>): StompClientConnection
- closeHandler(Handler<StompClientConnection>): StompClientConnection
- pingHandler(Handler<StompClientConnection>): StompClientConnection
- beginTX(String, Handler<AsyncResult<Frame>>): StompClientConnection
- beginTX(String): Future<Frame>
- beginTX(String, Map<String, String>): Future<Frame>
- beginTX(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- commit(String): Future<Frame>
- commit(String, Handler<AsyncResult<Frame>>): StompClientConnection
- commit(String, Map<String, String>): Future<Frame>
- commit(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- abort(String): Future<Frame>
- abort(String, Handler<AsyncResult<Frame>>): StompClientConnection
- abort(String, Map<String, String>): Future<Frame>
- abort(String, Map<String, String>, Handler<AsyncResult<Frame>>): StompClientConnection
- disconnect(): Future<Frame>
- disconnect(Frame): Future<Frame>
- disconnect(Handler<AsyncResult<Frame>>): StompClientConnection
- disconnect(Frame, Handler<AsyncResult<Frame>>): StompClientConnection
- ack(String): Future<Frame>
- ack(String, Handler<AsyncResult<Frame>>): StompClientConnection
- nack(String): Future<Frame>
- nack(String, Handler<AsyncResult<Frame>>): StompClientConnection
- ack(String, String): Future<Frame>
- ack(String, String, Handler<AsyncResult<Frame>>): StompClientConnection
- nack(String, String): Future<Frame>
- nack(String, String, Handler<AsyncResult<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
- connect(): Future<StompClientConnection>
- receivedFrameHandler(Handler<Frame>): StompClient
- writingFrameHandler(Handler<Frame>): StompClient
- errorFrameHandler(Handler<Frame>): StompClient
- exceptionHandler(Handler<Throwable>): StompClient
- connect(NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
- connect(NetClient): Future<StompClientConnection>
- connect(int, String): Future<StompClientConnection>
- close(): void
- options(): StompClientOptions
- vertx(): Vertx
- isClosed(): boolean
- connect(int, String, NetClient, Handler<AsyncResult<StompClientConnection>>): StompClient
- connect(int, String, NetClient): Future<StompClientConnection>
- 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(): Future<StompServer>
- listen(Handler<AsyncResult<StompServer>>): StompServer
- listen(int): Future<StompServer>
- listen(int, String): Future<StompServer>
- listen(int, Handler<AsyncResult<StompServer>>): StompServer
- listen(int, String, Handler<AsyncResult<StompServer>>): StompServer
- close(): Future<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
- sslSession(): SSLSession
- 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