Java Node类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.hazelcast.instance.Node类的典型用法代码示例。如果您正苦于以下问题：Java Node类的具体用法？Java Node怎么用？Java Node使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Node类属于com.hazelcast.instance包，在下文中一共展示了Node类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: TcpIpJoinerOverAWS

import com.hazelcast.instance.Node; //导入依赖的package包/类
public TcpIpJoinerOverAWS(Node node) {
    super(node);
    logger = node.getLogger(getClass());

    AwsConfig awsConfig = node.getConfig().getNetworkConfig().getJoin().getAwsConfig();
    aws = new AWSClient(awsConfig);
}

开发者ID:hazelcast，项目名称:hazelcast-aws，代码行数:8，代码来源:TcpIpJoinerOverAWS.java

示例2: isInstanceNotActive

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected boolean isInstanceNotActive(HazelcastInstance hz) {
    if (hz == null) {
        return true;
    }
    Node node = TestUtil.getNode(hz);
    return node == null || !node.isRunning();
}

开发者ID:hazelcast，项目名称:hazelcast-wm，代码行数:8，代码来源:AbstractWebFilterTest.java

示例3: ConsulJoiner

import com.hazelcast.instance.Node; //导入依赖的package包/类
public ConsulJoiner(final Node node, final ConsulConfig consulConfig) {
    super(node);
    this.consulConfig = consulConfig;
    
    // autoconnect to consul
    this.connect();
}

开发者ID:decoomanj，项目名称:hazelcast-consul，代码行数:8，代码来源:ConsulJoiner.java

示例4: AbstractJetMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected AbstractJetMessageTask(ClientMessage clientMessage, Node node, Connection connection,
                                 Function<ClientMessage, P> decoder, Function<Object, ClientMessage> encoder) {
    super(clientMessage, node, connection);

    this.decoder = decoder;
    this.encoder = encoder;
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:8，代码来源:AbstractJetMessageTask.java

示例5: getOperationService

import com.hazelcast.instance.Node; //导入依赖的package包/类
public static InternalOperationService getOperationService(HazelcastInstance hz) {
    Node node = checkNotNull(getNode(hz), "node is null in Hazelcast instance " + hz);
    NodeEngineImpl nodeEngine = node.getNodeEngine();
    try {
        return nodeEngine.getOperationService();
    } catch (NoSuchMethodError e) {
        // fallback for a binary incompatible change (see commit http://git.io/vtfKU)
        return getOperationServiceViaReflection(nodeEngine);
    }
}

开发者ID:hazelcast，项目名称:hazelcast-simulator，代码行数:11，代码来源:HazelcastTestUtils.java

示例6: getInternalPartitionService

import com.hazelcast.instance.Node; //导入依赖的package包/类
private InternalPartitionServiceImpl getInternalPartitionService() {
    Node node = nodeEngine.getNode();
    return (InternalPartitionServiceImpl) node.getPartitionService();
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JobCoordinationService.java

示例7: JetCancelJobMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetCancelJobMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetCancelJobCodec::decodeRequest,
            o -> JetCancelJobCodec.encodeResponse());
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetCancelJobMessageTask.java

示例8: JetSubmitJobMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetSubmitJobMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetSubmitJobCodec::decodeRequest,
            o -> JetSubmitJobCodec.encodeResponse());
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetSubmitJobMessageTask.java

示例9: JetGetJobStatusMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetGetJobStatusMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetGetJobStatusCodec::decodeRequest,
            o -> JetGetJobStatusCodec.encodeResponse((Data) o));
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetGetJobStatusMessageTask.java

示例10: JetGetJobIdsMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetGetJobIdsMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetGetJobIdsCodec::decodeRequest,
            o -> JetGetJobIdsCodec.encodeResponse((Data) o));
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetGetJobIdsMessageTask.java

示例11: JetJoinSubmittedJobMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetJoinSubmittedJobMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetJoinSubmittedJobCodec::decodeRequest,
            o -> JetJoinSubmittedJobCodec.encodeResponse((Data) o));
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetJoinSubmittedJobMessageTask.java

示例12: JetGetJobSubmissionTimeMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetGetJobSubmissionTimeMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetGetJobSubmissionTimeCodec::decodeRequest,
            o -> JetGetJobSubmissionTimeCodec.encodeResponse((long) o));
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetGetJobSubmissionTimeMessageTask.java

示例13: JetGetJobConfigMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetGetJobConfigMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetGetJobConfigCodec::decodeRequest,
            o -> JetGetJobConfigCodec.encodeResponse((Data) o));
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetGetJobConfigMessageTask.java

示例14: JetGetJobIdsByNameMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
protected JetGetJobIdsByNameMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection, JetGetJobIdsByNameCodec::decodeRequest,
            o -> JetGetJobIdsByNameCodec.encodeResponse((Data) o));
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:5，代码来源:JetGetJobIdsByNameMessageTask.java

示例15: unblacklistJoinerBetween

import com.hazelcast.instance.Node; //导入依赖的package包/类
private static void unblacklistJoinerBetween(HazelcastInstance h1, HazelcastInstance h2) {
    Node h1Node = getNode(h1);
    Node h2Node = getNode(h2);
    h1Node.getJoiner().unblacklist(h2Node.getThisAddress());
    h2Node.getJoiner().unblacklist(h1Node.getThisAddress());
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:7，代码来源:JetSplitBrainTestSupport.java

示例16: getNode

import com.hazelcast.instance.Node; //导入依赖的package包/类
public static Node getNode(JetInstance instance) {
    return getNode(hz(instance));
}

开发者ID:hazelcast，项目名称:hazelcast-jet，代码行数:4，代码来源:JetTestSupport.java

示例17: AbstractSnowcastMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
AbstractSnowcastMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection);
}

开发者ID:noctarius，项目名称:snowcast，代码行数:4，代码来源:AbstractSnowcastMessageTask.java

示例18: DestroySequencerDefinitionMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
DestroySequencerDefinitionMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection);
}

开发者ID:noctarius，项目名称:snowcast，代码行数:4，代码来源:DestroySequencerDefinitionMessageTask.java

示例19: CreateSequencerDefinitionMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
CreateSequencerDefinitionMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection);
}

开发者ID:noctarius，项目名称:snowcast，代码行数:4，代码来源:CreateSequencerDefinitionMessageTask.java

示例20: RemoveChannelMessageTask

import com.hazelcast.instance.Node; //导入依赖的package包/类
RemoveChannelMessageTask(ClientMessage clientMessage, Node node, Connection connection) {
    super(clientMessage, node, connection);
}

开发者ID:noctarius，项目名称:snowcast，代码行数:4，代码来源:RemoveChannelMessageTask.java

注：本文中的com.hazelcast.instance.Node类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。