本文整理了Java中io.vertx.core.VertxOptions.setClusterPublicPort()
方法的一些代码示例,展示了VertxOptions.setClusterPublicPort()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。VertxOptions.setClusterPublicPort()
方法的具体详情如下:
包路径:io.vertx.core.VertxOptions
类名称:VertxOptions
方法名:setClusterPublicPort
[英]See #setClusterPublicHost(String) for an explanation.
[中]有关说明,请参见#setClusterPublicHost(字符串)。
代码示例来源:origin: eclipse-vertx/vert.x
case "clusterPublicPort":
if (member.getValue() instanceof Number) {
obj.setClusterPublicPort(((Number)member.getValue()).intValue());
代码示例来源:origin: eclipse-vertx/vert.x
@Override
public void beforeStartingVertx(VertxOptions options) {
beforeStartingVertxInvoked = true;
this.options = options;
if (clusterHost != null) {
options.setClusterHost(clusterHost);
options.setClusterPort(clusterPort);
options.setClusterPublicHost(clusterPublicHost);
options.setClusterPublicPort(clusterPublicPort);
super.beforeStartingVertx(options);
}
}
代码示例来源:origin: eclipse-vertx/vert.x
.setClusterPublicHost(clusterPublicHost);
if (clusterPublicPort != -1) {
options.setClusterPublicPort(clusterPublicPort);
代码示例来源:origin: io.vertx/vertx-core
case "clusterPublicPort":
if (member.getValue() instanceof Number) {
obj.setClusterPublicPort(((Number)member.getValue()).intValue());
代码示例来源:origin: eclipse-vertx/vert.x
TimeUnit blockedThreadCheckIntervalUnit = TimeUnit.MINUTES;
options.setClusterPort(clusterPort);
options.setClusterPublicPort(clusterPublicPort);
options.setEventLoopPoolSize(eventLoopPoolSize);
options.setInternalBlockingPoolSize(internalBlockingPoolSize);
代码示例来源:origin: io.vertx/vertx-core
@Override
public void beforeStartingVertx(VertxOptions options) {
beforeStartingVertxInvoked = true;
this.options = options;
if (clusterHost != null) {
options.setClusterHost(clusterHost);
options.setClusterPort(clusterPort);
options.setClusterPublicHost(clusterPublicHost);
options.setClusterPublicPort(clusterPublicPort);
super.beforeStartingVertx(options);
}
}
代码示例来源:origin: io.vertx/vertx-core
.setClusterPublicHost(clusterPublicHost);
if (clusterPublicPort != -1) {
options.setClusterPublicPort(clusterPublicPort);
代码示例来源:origin: eclipse-vertx/vert.x
assertEquals(options, options.setClusterPublicPort(1234));
assertEquals(1234, options.getClusterPublicPort());
try {
options.setClusterPublicPort(-1);
fail("Should throw exception");
} catch (IllegalArgumentException e) {
options.setClusterPublicPort(65536);
fail("Should throw exception");
} catch (IllegalArgumentException e) {
代码示例来源:origin: io.vertx/vertx-core
TimeUnit blockedThreadCheckIntervalUnit = TimeUnit.MINUTES;
options.setClusterPort(clusterPort);
options.setClusterPublicPort(clusterPublicPort);
options.setEventLoopPoolSize(eventLoopPoolSize);
options.setInternalBlockingPoolSize(internalBlockingPoolSize);
代码示例来源:origin: io.vertx/vertx-core
assertEquals(options, options.setClusterPublicPort(1234));
assertEquals(1234, options.getClusterPublicPort());
try {
options.setClusterPublicPort(-1);
fail("Should throw exception");
} catch (IllegalArgumentException e) {
options.setClusterPublicPort(65536);
fail("Should throw exception");
} catch (IllegalArgumentException e) {
内容来源于网络,如有侵权,请联系作者删除!