/*
 *  Copyright (c) 2011-2015 The original author or authors
 *  ------------------------------------------------------
 *  All rights reserved. This program and the accompanying materials
 *  are made available under the terms of the Eclipse Public License v1.0
 *  and Apache License v2.0 which accompanies this distribution.
 *
 *       The Eclipse Public License is available at
 *       http://www.eclipse.org/legal/epl-v10.html
 *
 *       The Apache License v2.0 is available at
 *       http://www.opensource.org/licenses/apache2.0.php
 *
 *  You may elect to redistribute this code under either of these licenses.
 */

package io.vertx.ext.stomp;

import io.vertx.codegen.annotations.DataObject;
import io.vertx.core.json.JsonObject;
import io.vertx.core.net.NetClientOptions;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

Options used to configure a STOMP client. As a STOMP client wraps a Net client, you can also configure the underlying NET client.
Author:Clement Escoffier
/** * Options used to configure a STOMP client. As a STOMP client wraps a Net client, you can also configure the * underlying NET client. * * @author <a href="http://escoffier.me">Clement Escoffier</a> */
@DataObject(generateConverter = true) public class StompClientOptions extends NetClientOptions implements StompOptions { // The default value of reuse address for stomp client private static final boolean DEFAULT_CLIENT_REUSE_ADDRESS = false; private List<String> acceptedVersions; private int port = DEFAULT_STOMP_PORT; private String host = DEFAULT_STOMP_HOST; private String login; private String passcode; private boolean autoComputeContentLength = true; private boolean useStompFrame = false; private boolean bypassHostHeader = false; private JsonObject heartbeat = DEFAULT_STOMP_HEARTBEAT; private String virtualHost; private boolean trailingLine = DEFAULT_TRAILING_LINE;
Default constructor.
/** * Default constructor. */
public StompClientOptions() { super(); init(); // Override the DEFAULT_REUSE_ADDRESS value in NetworkOptions setReuseAddress(DEFAULT_CLIENT_REUSE_ADDRESS); }
Copy constructor.
Params:
/** * Copy constructor. * * @param other The other {@link StompServerOptions} to copy when creating this */
public StompClientOptions(StompClientOptions other) { super(other); this.port = other.port; this.host = other.host; this.login = other.login; this.passcode = other.passcode; this.autoComputeContentLength = other.autoComputeContentLength; this.acceptedVersions = new ArrayList<>(other.acceptedVersions); this.bypassHostHeader = other.bypassHostHeader; this.heartbeat = other.heartbeat; this.virtualHost = other.virtualHost; this.trailingLine = other.trailingLine; }
Creates an instance from a JsonObject.
Params:
  • json – the JsonObject to create it from
/** * Creates an instance from a {@link io.vertx.core.json.JsonObject}. * * @param json the JsonObject to create it from */
public StompClientOptions(JsonObject json) { super(json); init(); StompClientOptionsConverter.fromJson(json, this); // If no valid reuseAddress value specified in the json, set it with DEFAULT_CLIENT_REUSE_ADDRESS if(!(json.getValue("reuseAddress") instanceof Boolean)){ setReuseAddress(DEFAULT_CLIENT_REUSE_ADDRESS); } } private void init() { acceptedVersions = new ArrayList<>(DEFAULT_SUPPORTED_VERSIONS); Collections.reverse(acceptedVersions); }
Returns:a JSON representation of the options.
/** * @return a JSON representation of the options. */
public JsonObject toJson() { JsonObject json = new JsonObject(); StompClientOptionsConverter.toJson(this, json); return json; }
Gets the STOMP server host.
Returns:the STOMP server host
/** * Gets the STOMP server host. * * @return the STOMP server host */
public String getHost() { return host; }
Sets the STOMP server host. 0.0.0.0 by default.
Params:
  • host – the host name of the STOMP server
Returns:the current StompClientOptions
/** * Sets the STOMP server host. {@code 0.0.0.0} by default. * * @param host the host name of the STOMP server * @return the current {@link StompClientOptions} */
public StompClientOptions setHost(String host) { this.host = host; return this; }
Gets the configured login.
Returns:the login
/** * Gets the configured login. * * @return the login */
public String getLogin() { return login; }
Sets the login to use if the STOMP server is secured.
Params:
  • login – the login
Returns:the current StompClientOptions
/** * Sets the login to use if the STOMP server is secured. * * @param login the login * @return the current {@link StompClientOptions} */
public StompClientOptions setLogin(String login) { this.login = login; return this; }
Gets the configured passcode.
Returns:the passcode
/** * Gets the configured passcode. * * @return the passcode */
public String getPasscode() { return passcode; }
Sets the passcode to use if the STOMP server is secured.
Params:
  • passcode – the passcode
Returns:the current StompClientOptions
/** * Sets the passcode to use if the STOMP server is secured. * * @param passcode the passcode * @return the current {@link StompClientOptions} */
public StompClientOptions setPasscode(String passcode) { this.passcode = passcode; return this; }
Gets the STOMP server port.
Returns:the port
/** * Gets the STOMP server port. * * @return the port */
public int getPort() { return port; }
Sets the STOMP server port. 61613 by default.
Params:
  • port – the port
Returns:the current StompClientOptions
/** * Sets the STOMP server port. {@code 61613} by default. * * @param port the port * @return the current {@link StompClientOptions} */
public StompClientOptions setPort(int port) { this.port = port; return this; }
Gets the list of STOMP protocol versions accepted by the client.
Returns:the list of accepted version
/** * Gets the list of STOMP protocol versions accepted by the client. * * @return the list of accepted version */
public List<String> getAcceptedVersions() { return acceptedVersions; }
Sets the list of STOMP protocol versions accepted by the client. The list must be ordered from the lowest version to the highest. By default the following list is used: 1.0, 1.1, 1.2
Params:
  • acceptedVersions – the order list of accepted versions
Returns:the current StompClientOptions
/** * Sets the list of STOMP protocol versions accepted by the client. The list must be ordered from the lowest * version to the highest. By default the following list is used: {@code 1.0, 1.1, 1.2} * * @param acceptedVersions the order list of accepted versions * @return the current {@link StompClientOptions} */
public StompClientOptions setAcceptedVersions(List<String> acceptedVersions) { this.acceptedVersions = acceptedVersions; return this; }
Whether or not the automatic computation of the content-length header is enabled.
Returns:whether or not the option is enabled
/** * Whether or not the automatic computation of the {@code content-length} header is enabled. * * @return whether or not the option is enabled */
public boolean isAutoComputeContentLength() { return autoComputeContentLength; }
Sets whether or not the automatic computation of the content-length header is enabled. If enabled, the content-length header is set in all frame with a body that do not explicitly set the header. The option is enabled by default.
Params:
  • autoComputeContentLength – true to enable the option, false to disable it.
Returns:the current StompClientOptions
/** * Sets whether or not the automatic computation of the {@code content-length} header is enabled. If enabled, the * {@code content-length} header is set in all frame with a body that do not explicitly set the header. The option * is enabled by default. * * @param autoComputeContentLength {@code true} to enable the option, {@code false} to disable it. * @return the current {@link StompClientOptions} */
public StompClientOptions setAutoComputeContentLength(boolean autoComputeContentLength) { this.autoComputeContentLength = autoComputeContentLength; return this; }
Checks whether or not the connection is made using the STOMP command instead of the CONNECT command. The STOMP command has been introduced in the 1.2 version of the protocol to ease the network analysis (as CONNECT is also used by HTTP. To be compliant with server not implementing the 1.2 specification, this option should be disabled.
Returns:whether or not the option is enabled
/** * Checks whether or not the connection is made using the {@code STOMP} command instead of the {@code CONNECT} * command. The {@code STOMP} command has been introduced in the 1.2 version of the protocol to ease the network * analysis (as {@code CONNECT} is also used by HTTP. To be compliant with server not implementing the 1.2 * specification, this option should be disabled. * * @return whether or not the option is enabled */
public boolean isUseStompFrame() { return useStompFrame; }
Sets whether or not the connection is made using the STOMP command instead of the CONNECT command. The STOMP command has been introduced in the 1.2 version of the protocol to ease the network analysis (as CONNECT is also used by HTTP. To be compliant with server not implementing the 1.2 specification, this option should be disabled. This option is disabled by default.
Params:
  • useStompFrame – true to enable the option, false to disable it.
Returns:the current StompClientOptions
/** * Sets whether or not the connection is made using the {@code STOMP} command instead of the {@code CONNECT} command. * The {@code STOMP} command has been introduced in the 1.2 version of the protocol to ease the network analysis * (as {@code CONNECT} is also used by HTTP. To be compliant with server not implementing the 1.2 specification, * this option should be disabled. This option is disabled by default. * * @param useStompFrame {@code true} to enable the option, {@code false} to disable it. * @return the current {@link StompClientOptions} */
public StompClientOptions setUseStompFrame(boolean useStompFrame) { this.useStompFrame = useStompFrame; return this; } @Override public StompClientOptions setSsl(boolean ssl) { super.setSsl(ssl); return this; }
Checks whether or not the host header must be dropped from the CONNECT/STOMP frame. Server may be picky about this header (such as RabbitMQ that does not support it).
Returns:whether or not the option is enabled
/** * Checks whether or not the {@code host} header must be dropped from the {@code CONNECT/STOMP} frame. Server may * be picky about this header (such as RabbitMQ that does not support it). * * @return whether or not the option is enabled */
public boolean isBypassHostHeader() { return bypassHostHeader; }
Sets whether or not the host header must be dropped from the CONNECT/STOMP frame. Server may be picky about this header (such as RabbitMQ that does not support it). Options disabled by default.
Params:
  • bypassHostHeader – true to enable the option, false to disable it.
Returns:the current StompClientOptions
/** * Sets whether or not the {@code host} header must be dropped from the {@code CONNECT/STOMP} frame. Server may * be picky about this header (such as RabbitMQ that does not support it). Options disabled by default. * * @param bypassHostHeader {@code true} to enable the option, {@code false} to disable it. * @return the current {@link StompClientOptions} */
public StompClientOptions setBypassHostHeader(boolean bypassHostHeader) { this.bypassHostHeader = bypassHostHeader; return this; }
Gets the heartbeat configuration.
See Also:
Returns:the heartbeat configuration
/** * Gets the heartbeat configuration. * * @return the heartbeat configuration * @see io.vertx.ext.stomp.Frame.Heartbeat */
public JsonObject getHeartbeat() { return heartbeat; }
Sets the heartbeat configuration.
Params:
  • heartbeat – the configuration
See Also:
Returns:the current StompClientOptions
/** * Sets the heartbeat configuration. * * @param heartbeat the configuration * @return the current {@link StompClientOptions} * @see io.vertx.ext.stomp.Frame.Heartbeat */
public StompClientOptions setHeartbeat(JsonObject heartbeat) { this.heartbeat = heartbeat; return this; }
Gets the virtual host that would be use a "host" header value in the `CONNECT` frame. This option is useful for Cloud AMQP.
Returns:the virtual host
/** * Gets the virtual host that would be use a "host" header value in the `CONNECT` frame. This option is useful for * Cloud AMQP. * * @return the virtual host */
public String getVirtualHost() { return virtualHost; }
Sets the virtual host that will be used as "host" header value in the `CONNECT` frame.
Params:
  • virtualHost – the virtual host
Returns:the current StompClientOptions
/** * Sets the virtual host that will be used as "host" header value in the `CONNECT` frame. * * @param virtualHost the virtual host * @return the current {@link StompClientOptions} */
public StompClientOptions setVirtualHost(String virtualHost) { this.virtualHost = virtualHost; return this; }
Gets whether or not an empty line should be appended to the written STOMP frame. This option is disabled by default. This option is not compliant with the STOMP specification, and so is not documented on purpose.
Returns:whether or not an empty line should be appended to the written STOMP frame.
/** * Gets whether or not an empty line should be appended to the written STOMP frame. This option is disabled by * default. This option is not compliant with the STOMP specification, and so is not documented on purpose. * * @return whether or not an empty line should be appended to the written STOMP frame. */
public boolean isTrailingLine() { return trailingLine; }
Sets whether or not an empty line should be appended to the written STOMP frame. This option is disabled by default. This option is not compliant with the STOMP specification, and so is not documented on purpose.
Params:
  • trailingLine – true to add an empty line, false otherwise
Returns:the current StompClientOptions
/** * Sets whether or not an empty line should be appended to the written STOMP frame. This option is disabled by * default. This option is not compliant with the STOMP specification, and so is not documented on purpose. * * @param trailingLine {@code true} to add an empty line, {@code false} otherwise * @return the current {@link StompClientOptions} */
public StompClientOptions setTrailingLine(boolean trailingLine) { this.trailingLine = trailingLine; return this; } }