public class io.vertx.core.spi.cluster.impl.DefaultNodeSelector extends java.lang.Object implements io.vertx.core.spi.cluster.NodeSelector
{
private io.vertx.core.spi.cluster.impl.selector.Selectors selectors;
public void <init>()
{
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void init(io.vertx.core.Vertx, io.vertx.core.spi.cluster.ClusterManager)
{
io.vertx.core.spi.cluster.impl.selector.Selectors v;
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
io.vertx.core.spi.cluster.ClusterManager v;
io.vertx.core.Vertx v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
v := @parameter: io.vertx.core.Vertx;
v := @parameter: io.vertx.core.spi.cluster.ClusterManager;
v = new io.vertx.core.spi.cluster.impl.selector.Selectors;
specialinvoke v.<io.vertx.core.spi.cluster.impl.selector.Selectors: void <init>(io.vertx.core.spi.cluster.ClusterManager)>(v);
v.<io.vertx.core.spi.cluster.impl.DefaultNodeSelector: io.vertx.core.spi.cluster.impl.selector.Selectors selectors> = v;
return;
}
public void eventBusStarted()
{
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
return;
}
public void selectForSend(io.vertx.core.eventbus.Message, io.vertx.core.Promise)
{
io.vertx.core.spi.cluster.impl.selector.Selectors v;
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
io.vertx.core.Promise v;
java.util.function.BiConsumer v;
io.vertx.core.eventbus.Message v;
boolean v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
v := @parameter: io.vertx.core.eventbus.Message;
v := @parameter: io.vertx.core.Promise;
v = interfaceinvoke v.<io.vertx.core.eventbus.Message: boolean isSend()>();
staticinvoke <io.vertx.core.impl.Arguments: void require(boolean,java.lang.String)>(v, "selectForSend used for publishing");
v = v.<io.vertx.core.spi.cluster.impl.DefaultNodeSelector: io.vertx.core.spi.cluster.impl.selector.Selectors selectors>;
v = staticinvoke <io.vertx.core.spi.cluster.impl.DefaultNodeSelector$lambda_selectForSend_0__1180: java.util.function.BiConsumer bootstrap$()>();
virtualinvoke v.<io.vertx.core.spi.cluster.impl.selector.Selectors: void withSelector(io.vertx.core.eventbus.Message,io.vertx.core.Promise,java.util.function.BiConsumer)>(v, v, v);
return;
}
public void selectForPublish(io.vertx.core.eventbus.Message, io.vertx.core.Promise)
{
io.vertx.core.spi.cluster.impl.selector.Selectors v;
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
io.vertx.core.Promise v;
java.util.function.BiConsumer v;
io.vertx.core.eventbus.Message v;
boolean v, v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
v := @parameter: io.vertx.core.eventbus.Message;
v := @parameter: io.vertx.core.Promise;
v = interfaceinvoke v.<io.vertx.core.eventbus.Message: boolean isSend()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <io.vertx.core.impl.Arguments: void require(boolean,java.lang.String)>(v, "selectForPublish used for sending");
v = v.<io.vertx.core.spi.cluster.impl.DefaultNodeSelector: io.vertx.core.spi.cluster.impl.selector.Selectors selectors>;
v = staticinvoke <io.vertx.core.spi.cluster.impl.DefaultNodeSelector$lambda_selectForPublish_1__1181: java.util.function.BiConsumer bootstrap$()>();
virtualinvoke v.<io.vertx.core.spi.cluster.impl.selector.Selectors: void withSelector(io.vertx.core.eventbus.Message,io.vertx.core.Promise,java.util.function.BiConsumer)>(v, v, v);
return;
}
public void registrationsUpdated(io.vertx.core.spi.cluster.RegistrationUpdateEvent)
{
io.vertx.core.spi.cluster.impl.selector.Selectors v;
java.util.List v;
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
io.vertx.core.spi.cluster.RegistrationUpdateEvent v;
java.lang.String v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
v := @parameter: io.vertx.core.spi.cluster.RegistrationUpdateEvent;
v = v.<io.vertx.core.spi.cluster.impl.DefaultNodeSelector: io.vertx.core.spi.cluster.impl.selector.Selectors selectors>;
v = virtualinvoke v.<io.vertx.core.spi.cluster.RegistrationUpdateEvent: java.lang.String address()>();
v = virtualinvoke v.<io.vertx.core.spi.cluster.RegistrationUpdateEvent: java.util.List registrations()>();
virtualinvoke v.<io.vertx.core.spi.cluster.impl.selector.Selectors: void dataReceived(java.lang.String,java.util.List,boolean)>(v, v, 1);
return;
}
public void registrationsLost()
{
io.vertx.core.spi.cluster.impl.selector.Selectors v;
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
v = v.<io.vertx.core.spi.cluster.impl.DefaultNodeSelector: io.vertx.core.spi.cluster.impl.selector.Selectors selectors>;
virtualinvoke v.<io.vertx.core.spi.cluster.impl.selector.Selectors: void dataLost()>();
return;
}
public boolean wantsUpdatesFor(java.lang.String)
{
io.vertx.core.spi.cluster.impl.selector.Selectors v;
io.vertx.core.spi.cluster.impl.DefaultNodeSelector v;
java.lang.String v;
boolean v;
v := @this: io.vertx.core.spi.cluster.impl.DefaultNodeSelector;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.spi.cluster.impl.DefaultNodeSelector: io.vertx.core.spi.cluster.impl.selector.Selectors selectors>;
v = virtualinvoke v.<io.vertx.core.spi.cluster.impl.selector.Selectors: boolean hasEntryFor(java.lang.String)>(v);
return v;
}
}