Giriş
Şu satırı dahil ederiz
import com.hazelcast.instance.impl.Node;
Kod şöyle. HazelcastInstanceImpl sınıfının bir alanıdır. Bazı servisler bu sınıfın içindedir. Bazı servisler de NodeEngineImpl içindedir.
public class Node {
// name of property used to inject ClusterTopologyIntentTracker in Discovery Service
public static final String DISCOVERY_PROPERTY_CLUSTER_TOPOLOGY_INTENT_TRACKER =
"hazelcast.internal.discovery.cluster.topology.intent.tracker";
private static final int THREAD_SLEEP_DURATION_MS = 500;
private static final String GRACEFUL_SHUTDOWN_EXECUTOR_NAME = "hz:graceful-shutdown";
public final HazelcastInstanceImpl hazelcastInstance;
public final DynamicConfigurationAwareConfig config;
public final NodeEngineImpl nodeEngine;
public final ClientEngine clientEngine;
public final InternalPartitionServiceImpl partitionService;
public final ClusterServiceImpl clusterService;
public final MulticastService multicastService;
public final DiscoveryService discoveryService;
public final TextCommandService textCommandService;
public final LoggingServiceImpl loggingService;
public final Server server;
/**
* Member-to-member address only.
* When the Node is configured with multiple endpoints, this address still
* represents ProtocolType.MEMBER
* For accessing a full address-map, see AddressPicker.getPublicAddressMap()
*/
public final Address address;
public final SecurityContext securityContext;
final ClusterTopologyIntentTracker clusterTopologyIntentTracker;
private final ILogger logger;
private final AtomicBoolean shuttingDown = new AtomicBoolean(false);
private final NodeShutdownHookThread shutdownHookThread;
private final MemberSchemaService schemaService;
private final InternalSerializationService serializationService;
private final InternalSerializationService compatibilitySerializationService;
private final ClassLoader configClassLoader;
private final NodeExtension nodeExtension;
private final HazelcastProperties properties;
private final BuildInfo buildInfo;
private final HealthMonitor healthMonitor;
private final Joiner joiner;
private final LocalAddressRegistry localAddressRegistry;
private ManagementCenterService managementCenterService;
// it can be changed on cluster service reset
//see: ClusterServiceImpl#resetLocalMemberUuid
private volatile UUID thisUuid;
private volatile NodeState state = NodeState.STARTING;
...
}start metodu
NodeEngineImpl nesnesini ve servisleri başlatır
Hiç yorum yok:
Yorum Gönder