public class io.vertx.core.eventbus.EventBusOptions extends io.vertx.core.net.TCPSSLOptions
{
public static final java.lang.String DEFAULT_CLUSTER_HOST;
public static final int DEFAULT_CLUSTER_PORT;
public static final java.lang.String DEFAULT_CLUSTER_PUBLIC_HOST;
public static final int DEFAULT_CLUSTER_PUBLIC_PORT;
public static final long DEFAULT_CLUSTER_PING_INTERVAL;
public static final long DEFAULT_CLUSTER_PING_REPLY_INTERVAL;
private java.lang.String clusterPublicHost;
private int clusterPublicPort;
private long clusterPingInterval;
private long clusterPingReplyInterval;
private io.vertx.core.json.JsonObject clusterNodeMetadata;
public static final int DEFAULT_ACCEPT_BACKLOG;
public static final io.vertx.core.http.ClientAuth DEFAULT_CLIENT_AUTH;
private int port;
private java.lang.String host;
private int acceptBacklog;
private io.vertx.core.http.ClientAuth clientAuth;
public static final int DEFAULT_RECONNECT_ATTEMPTS;
public static final long DEFAULT_RECONNECT_INTERVAL;
public static final int DEFAULT_CONNECT_TIMEOUT;
public static final boolean DEFAULT_TRUST_ALL;
private int reconnectAttempts;
private long reconnectInterval;
private int connectTimeout;
private boolean trustAll;
public void <init>()
{
long v, v;
int v, v, v;
io.vertx.core.http.ClientAuth v, v;
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v, v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: void <init>()>();
v = <io.vertx.core.eventbus.EventBusOptions: java.lang.String DEFAULT_CLUSTER_PUBLIC_HOST>;
v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String clusterPublicHost> = v;
v = (int) -1;
v.<io.vertx.core.eventbus.EventBusOptions: int clusterPublicPort> = v;
v = <io.vertx.core.eventbus.EventBusOptions: long DEFAULT_CLUSTER_PING_INTERVAL>;
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingInterval> = v;
v = <io.vertx.core.eventbus.EventBusOptions: long DEFAULT_CLUSTER_PING_REPLY_INTERVAL>;
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingReplyInterval> = v;
v = <io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth DEFAULT_CLIENT_AUTH>;
v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth clientAuth> = v;
v.<io.vertx.core.eventbus.EventBusOptions: int port> = 0;
v = <io.vertx.core.eventbus.EventBusOptions: java.lang.String DEFAULT_CLUSTER_HOST>;
v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String host> = v;
v = (int) -1;
v.<io.vertx.core.eventbus.EventBusOptions: int acceptBacklog> = v;
v = <io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth DEFAULT_CLIENT_AUTH>;
v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth clientAuth> = v;
v.<io.vertx.core.eventbus.EventBusOptions: int reconnectAttempts> = 0;
v.<io.vertx.core.eventbus.EventBusOptions: long reconnectInterval> = 1000L;
v = (int) 60000;
v.<io.vertx.core.eventbus.EventBusOptions: int connectTimeout> = v;
v.<io.vertx.core.eventbus.EventBusOptions: boolean trustAll> = 1;
return;
}
public void <init>(io.vertx.core.eventbus.EventBusOptions)
{
long v, v, v, v, v;
int v, v, v, v, v, v;
io.vertx.core.json.JsonObject v, v, v;
io.vertx.core.eventbus.EventBusOptions v, v;
java.lang.String v, v, v;
boolean v;
io.vertx.core.http.ClientAuth v, v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.eventbus.EventBusOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: void <init>(io.vertx.core.net.TCPSSLOptions)>(v);
v = <io.vertx.core.eventbus.EventBusOptions: java.lang.String DEFAULT_CLUSTER_PUBLIC_HOST>;
v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String clusterPublicHost> = v;
v = (int) -1;
v.<io.vertx.core.eventbus.EventBusOptions: int clusterPublicPort> = v;
v = <io.vertx.core.eventbus.EventBusOptions: long DEFAULT_CLUSTER_PING_INTERVAL>;
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingInterval> = v;
v = <io.vertx.core.eventbus.EventBusOptions: long DEFAULT_CLUSTER_PING_REPLY_INTERVAL>;
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingReplyInterval> = v;
v = <io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth DEFAULT_CLIENT_AUTH>;
v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth clientAuth> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String clusterPublicHost>;
v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String clusterPublicHost> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: int clusterPublicPort>;
v.<io.vertx.core.eventbus.EventBusOptions: int clusterPublicPort> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingInterval>;
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingInterval> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingReplyInterval>;
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingReplyInterval> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.json.JsonObject clusterNodeMetadata>;
if v != null goto label;
v = null;
goto label;
label:
v = v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.json.JsonObject clusterNodeMetadata>;
v = virtualinvoke v.<io.vertx.core.json.JsonObject: io.vertx.core.json.JsonObject copy()>();
label:
v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.json.JsonObject clusterNodeMetadata> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: int port>;
v.<io.vertx.core.eventbus.EventBusOptions: int port> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String host>;
v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String host> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: int acceptBacklog>;
v.<io.vertx.core.eventbus.EventBusOptions: int acceptBacklog> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth clientAuth>;
v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth clientAuth> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: long reconnectInterval>;
v.<io.vertx.core.eventbus.EventBusOptions: long reconnectInterval> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: int reconnectAttempts>;
v.<io.vertx.core.eventbus.EventBusOptions: int reconnectAttempts> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: int connectTimeout>;
v.<io.vertx.core.eventbus.EventBusOptions: int connectTimeout> = v;
v = v.<io.vertx.core.eventbus.EventBusOptions: boolean trustAll>;
v.<io.vertx.core.eventbus.EventBusOptions: boolean trustAll> = v;
return;
}
public void <init>(io.vertx.core.json.JsonObject)
{
io.vertx.core.json.JsonObject v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.json.JsonObject;
specialinvoke v.<io.vertx.core.eventbus.EventBusOptions: void <init>()>();
staticinvoke <io.vertx.core.eventbus.EventBusOptionsConverter: void fromJson(java.lang.Iterable,io.vertx.core.eventbus.EventBusOptions)>(v, v);
return;
}
public io.vertx.core.json.JsonObject toJson()
{
int v, v;
io.vertx.core.json.JsonObject v;
io.vertx.core.eventbus.EventBusOptions v;
java.lang.Integer v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = new io.vertx.core.json.JsonObject;
specialinvoke v.<io.vertx.core.json.JsonObject: void <init>()>();
staticinvoke <io.vertx.core.eventbus.EventBusOptionsConverter: void toJson(io.vertx.core.eventbus.EventBusOptions,io.vertx.core.json.JsonObject)>(v, v);
v = virtualinvoke v.<io.vertx.core.json.JsonObject: boolean containsKey(java.lang.String)>("clusterPublicPort");
if v == 0 goto label;
v = virtualinvoke v.<io.vertx.core.json.JsonObject: java.lang.Integer getInteger(java.lang.String)>("clusterPublicPort");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = (int) -1;
if v != v goto label;
virtualinvoke v.<io.vertx.core.json.JsonObject: java.lang.Object remove(java.lang.String)>("clusterPublicPort");
label:
return v;
}
public io.vertx.core.http.ClientAuth getClientAuth()
{
io.vertx.core.http.ClientAuth v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth clientAuth>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setClientAuth(io.vertx.core.http.ClientAuth)
{
io.vertx.core.http.ClientAuth v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.http.ClientAuth;
v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth clientAuth> = v;
return v;
}
public int getAcceptBacklog()
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: int acceptBacklog>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setAcceptBacklog(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
v.<io.vertx.core.eventbus.EventBusOptions: int acceptBacklog> = v;
return v;
}
public java.lang.String getHost()
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String host>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setHost(java.lang.String)
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.lang.String;
v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String host> = v;
return v;
}
public int getPort()
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: int port>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setPort(int)
{
int v, v;
io.vertx.core.eventbus.EventBusOptions v;
java.lang.IllegalArgumentException v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
if v < 0 goto label;
v = (int) 65535;
if v <= v goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("clusterPort p must be in range 0 <= p <= 65535");
throw v;
label:
v.<io.vertx.core.eventbus.EventBusOptions: int port> = v;
return v;
}
public int getReconnectAttempts()
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: int reconnectAttempts>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setReconnectAttempts(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
v.<io.vertx.core.eventbus.EventBusOptions: int reconnectAttempts> = v;
return v;
}
public long getReconnectInterval()
{
long v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: long reconnectInterval>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setReconnectInterval(long)
{
long v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: long;
v.<io.vertx.core.eventbus.EventBusOptions: long reconnectInterval> = v;
return v;
}
public io.vertx.core.eventbus.EventBusOptions addCrlPath(java.lang.String) throws java.lang.NullPointerException
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.lang.String;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions addCrlPath(java.lang.String)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions addCrlValue(io.vertx.core.buffer.Buffer) throws java.lang.NullPointerException
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.buffer.Buffer v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.buffer.Buffer;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions addCrlValue(io.vertx.core.buffer.Buffer)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions addEnabledCipherSuite(java.lang.String)
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.lang.String;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions addEnabledCipherSuite(java.lang.String)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions removeEnabledCipherSuite(java.lang.String)
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.lang.String;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions removeEnabledCipherSuite(java.lang.String)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setIdleTimeout(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setIdleTimeout(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setReadIdleTimeout(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setReadIdleTimeout(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setWriteIdleTimeout(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setWriteIdleTimeout(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setIdleTimeoutUnit(java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.util.concurrent.TimeUnit;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setIdleTimeoutUnit(java.util.concurrent.TimeUnit)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setKeyCertOptions(io.vertx.core.net.KeyCertOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.KeyCertOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.KeyCertOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setKeyCertOptions(io.vertx.core.net.KeyCertOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setKeyStoreOptions(io.vertx.core.net.JksOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.JksOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.JksOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setKeyStoreOptions(io.vertx.core.net.JksOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setPemKeyCertOptions(io.vertx.core.net.PemKeyCertOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.PemKeyCertOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.PemKeyCertOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setPemKeyCertOptions(io.vertx.core.net.PemKeyCertOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setPemTrustOptions(io.vertx.core.net.PemTrustOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.PemTrustOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.PemTrustOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setPemTrustOptions(io.vertx.core.net.PemTrustOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setPfxKeyCertOptions(io.vertx.core.net.PfxOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.PfxOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.PfxOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setPfxKeyCertOptions(io.vertx.core.net.PfxOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setPfxTrustOptions(io.vertx.core.net.PfxOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.PfxOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.PfxOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setPfxTrustOptions(io.vertx.core.net.PfxOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setSoLinger(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setSoLinger(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setSsl(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setSsl(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTcpKeepAlive(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTcpKeepAlive(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTcpNoDelay(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTcpNoDelay(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTrustOptions(io.vertx.core.net.TrustOptions)
{
io.vertx.core.net.TrustOptions v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.TrustOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTrustOptions(io.vertx.core.net.TrustOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTrustStoreOptions(io.vertx.core.net.JksOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.JksOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.JksOptions;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTrustStoreOptions(io.vertx.core.net.JksOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setReceiveBufferSize(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setReceiveBufferSize(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setReuseAddress(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setReuseAddress(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setReusePort(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setReusePort(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setSendBufferSize(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setSendBufferSize(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTrafficClass(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTrafficClass(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setUseAlpn(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setUseAlpn(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setSslEngineOptions(io.vertx.core.net.SSLEngineOptions)
{
io.vertx.core.net.SSLEngineOptions v;
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.SSLEngineOptions;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setSslEngineOptions(io.vertx.core.net.SSLEngineOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setJdkSslEngineOptions(io.vertx.core.net.JdkSSLEngineOptions)
{
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.JdkSSLEngineOptions v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.JdkSSLEngineOptions;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setJdkSslEngineOptions(io.vertx.core.net.JdkSSLEngineOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setOpenSslEngineOptions(io.vertx.core.net.OpenSSLEngineOptions)
{
io.vertx.core.net.OpenSSLEngineOptions v;
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.net.OpenSSLEngineOptions;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setOpenSslEngineOptions(io.vertx.core.net.OpenSSLEngineOptions)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setEnabledSecureTransportProtocols(java.util.Set)
{
java.util.Set v;
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.util.Set;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setEnabledSecureTransportProtocols(java.util.Set)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions addEnabledSecureTransportProtocol(java.lang.String)
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.lang.String;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions addEnabledSecureTransportProtocol(java.lang.String)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions removeEnabledSecureTransportProtocol(java.lang.String)
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.lang.String;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions removeEnabledSecureTransportProtocol(java.lang.String)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTcpFastOpen(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTcpFastOpen(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTcpCork(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTcpCork(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTcpQuickAck(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTcpQuickAck(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTcpUserTimeout(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setTcpUserTimeout(int)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setLogActivity(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setLogActivity(boolean)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setSslHandshakeTimeout(long)
{
long v;
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: long;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setSslHandshakeTimeout(long)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setSslHandshakeTimeoutUnit(java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
io.vertx.core.eventbus.EventBusOptions v;
io.vertx.core.net.TCPSSLOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.util.concurrent.TimeUnit;
v = specialinvoke v.<io.vertx.core.net.TCPSSLOptions: io.vertx.core.net.TCPSSLOptions setSslHandshakeTimeoutUnit(java.util.concurrent.TimeUnit)>(v);
return v;
}
public io.vertx.core.eventbus.EventBusOptions setTrustAll(boolean)
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: boolean;
v.<io.vertx.core.eventbus.EventBusOptions: boolean trustAll> = v;
return v;
}
public boolean isTrustAll()
{
io.vertx.core.eventbus.EventBusOptions v;
boolean v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: boolean trustAll>;
return v;
}
public int getConnectTimeout()
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: int connectTimeout>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setConnectTimeout(int)
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
v.<io.vertx.core.eventbus.EventBusOptions: int connectTimeout> = v;
return v;
}
public long getClusterPingInterval()
{
long v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingInterval>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setClusterPingInterval(long)
{
byte v;
long v;
io.vertx.core.eventbus.EventBusOptions v;
java.lang.IllegalArgumentException v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: long;
v = v cmp 1L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("clusterPingInterval must be greater than 0");
throw v;
label:
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingInterval> = v;
return v;
}
public long getClusterPingReplyInterval()
{
long v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingReplyInterval>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setClusterPingReplyInterval(long)
{
byte v;
long v;
io.vertx.core.eventbus.EventBusOptions v;
java.lang.IllegalArgumentException v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: long;
v = v cmp 1L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("clusterPingReplyInterval must be greater than 0");
throw v;
label:
v.<io.vertx.core.eventbus.EventBusOptions: long clusterPingReplyInterval> = v;
return v;
}
public java.lang.String getClusterPublicHost()
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String clusterPublicHost>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setClusterPublicHost(java.lang.String)
{
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: java.lang.String;
v.<io.vertx.core.eventbus.EventBusOptions: java.lang.String clusterPublicHost> = v;
return v;
}
public int getClusterPublicPort()
{
int v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: int clusterPublicPort>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setClusterPublicPort(int)
{
int v, v;
io.vertx.core.eventbus.EventBusOptions v;
java.lang.IllegalArgumentException v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: int;
if v < 0 goto label;
v = (int) 65535;
if v <= v goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("clusterPublicPort p must be in range 0 <= p <= 65535");
throw v;
label:
v.<io.vertx.core.eventbus.EventBusOptions: int clusterPublicPort> = v;
return v;
}
public io.vertx.core.json.JsonObject getClusterNodeMetadata()
{
io.vertx.core.json.JsonObject v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v = v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.json.JsonObject clusterNodeMetadata>;
return v;
}
public io.vertx.core.eventbus.EventBusOptions setClusterNodeMetadata(io.vertx.core.json.JsonObject)
{
io.vertx.core.json.JsonObject v;
io.vertx.core.eventbus.EventBusOptions v;
v := @this: io.vertx.core.eventbus.EventBusOptions;
v := @parameter: io.vertx.core.json.JsonObject;
v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.json.JsonObject clusterNodeMetadata> = v;
return v;
}
static void <clinit>()
{
java.util.concurrent.TimeUnit v, v;
io.vertx.core.http.ClientAuth v;
long v, v;
<io.vertx.core.eventbus.EventBusOptions: java.lang.String DEFAULT_CLUSTER_HOST> = null;
<io.vertx.core.eventbus.EventBusOptions: java.lang.String DEFAULT_CLUSTER_PUBLIC_HOST> = null;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(20L);
<io.vertx.core.eventbus.EventBusOptions: long DEFAULT_CLUSTER_PING_INTERVAL> = v;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(20L);
<io.vertx.core.eventbus.EventBusOptions: long DEFAULT_CLUSTER_PING_REPLY_INTERVAL> = v;
v = <io.vertx.core.http.ClientAuth: io.vertx.core.http.ClientAuth NONE>;
<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.http.ClientAuth DEFAULT_CLIENT_AUTH> = v;
return;
}
}