Package com.hazelcast.client.config

Examples of com.hazelcast.client.config.ClientConfig

308
309
310
311
312
313
314
315
316
317
318
319
320
                    latch.countDown();
                }
            }
        };
        final ListenerConfig listenerConfig = new ListenerConfig(listener);
        final ClientConfig clientConfig = new ClientConfig();
        clientConfig.addListenerConfig(listenerConfig);
        clientConfig.getNetworkConfig().setConnectionAttemptLimit(100);
        final HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);

        Thread.sleep(100);

        instance.shutdown();
View Full Code Here
331
332
333
334
335
336
337
338
339
340
341
342
     */
    @Test
    public void testIssue1181() throws InterruptedException {
        final CountDownLatch latch = new CountDownLatch(1);
        Hazelcast.newHazelcastInstance();
        final ClientConfig clientConfig = new ClientConfig();
        clientConfig.addListenerConfig(new ListenerConfig().setImplementation(new InitialMembershipListener() {
            public void init(InitialMembershipEvent event) {
                for (int i = 0; i < event.getMembers().size(); i++) {
                    latch.countDown();
                }
            }
View Full Code Here
439
440
441
442
443
444
445
446
447
448
449
450
        serializationConfig.addPortableFactory(5, new PortableFactory() {
            public Portable create(int classId) {
                return new SamplePortable();
            }
        });
        final ClientConfig clientConfig = new ClientConfig();
        clientConfig.setSerializationConfig(serializationConfig);

        final HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);

        final IMap<Integer, SamplePortable> sampleMap = client.getMap(randomString());
        sampleMap.put(1, new SamplePortable(666));
View Full Code Here
456
457
458
459
460
461
462
463
464
465
466
467
    public void testCredentials() {
        final Config config = new Config();
        config.getGroupConfig().setName("foo").setPassword("bar");
        final HazelcastInstance instance = Hazelcast.newHazelcastInstance(config);

        final ClientConfig clientConfig = new ClientConfig();
        final ClientSecurityConfig securityConfig = clientConfig.getSecurityConfig();
        securityConfig.setCredentialsClassname(MyCredentials.class.getName());

        final HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);

    }
View Full Code Here
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
    @Test
    public void testNearCache_WhenRegisteredNodeIsDead() {

        final HazelcastInstance instance = Hazelcast.newHazelcastInstance();

        final ClientConfig clientConfig = new ClientConfig();
        final String mapName = randomMapName();

        NearCacheConfig nearCacheConfig = new NearCacheConfig();

        nearCacheConfig.setName(mapName);
        nearCacheConfig.setInvalidateOnChange(true);
        clientConfig.addNearCacheConfig(nearCacheConfig);

        final HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);

        final IMap<Object, Object> map = client.getMap(mapName);
View Full Code Here
584
585
586
587
588
589
590
591
592
593
594
595
    }

    private void testLock_WhenClientAndOwnerNodeDiesTogether(boolean smart) throws InterruptedException {

        Hazelcast.newHazelcastInstance();
        final ClientConfig clientConfig = new ClientConfig();
        clientConfig.getNetworkConfig().setSmartRouting(smart);

        final int tryCount = 5;

        for (int i = 0; i < tryCount; i++) {
            final HazelcastInstance instance = Hazelcast.newHazelcastInstance();
View Full Code Here
603
604
605
606
607
608
609
610
611
612
613
    }

    @Test
    public void testDeadlock_WhenDoingOperationFromListeners() {
        Hazelcast.newHazelcastInstance();
        final HazelcastInstance client = HazelcastClient.newHazelcastClient(new ClientConfig().setExecutorPoolSize(1));

        final int putCount = 1000;

        final CountDownLatch latch = new CountDownLatch(putCount);
View Full Code Here
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
        }
    }

    @Test
    public void testNearCache_shutdownClient() {
        final ClientConfig clientConfig = new ClientConfig();
        NearCacheConfig invalidateConfig = new NearCacheConfig();
        final String mapName = randomMapName();
        invalidateConfig.setName(mapName);
        invalidateConfig.setInvalidateOnChange(true);
        clientConfig.addNearCacheConfig(invalidateConfig);
        Hazelcast.newHazelcastInstance();
        final HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);

        final IMap<Integer, Integer> map = client.getMap(mapName);
View Full Code Here
29
30
31
32
33
34
35
36
37
38
    private HazelcastInstance client;

    @Before
    public void launchHazelcastServer() {
        Hazelcast.newHazelcastInstance();
        ClientConfig config = new ClientConfig();
        config.setGroupConfig(new GroupConfig("dev", "dev-pass"));
        config.getNetworkConfig().addAddress("127.0.0.1");
        client = HazelcastClient.newHazelcastClient(config);
    }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
    }

    public SerializationService createSerializationService() {
        SerializationService ss;
        try {
            ClientConfig config = client.getClientConfig();
            ClassLoader configClassLoader = config.getClassLoader();

            HazelcastInstance hazelcastInstance = client;
            PartitioningStrategy partitioningStrategy = getPartitioningStrategy(configClassLoader);

            SerializationServiceBuilder builder = new DefaultSerializationServiceBuilder();
            SerializationConfig serializationConfig = config.getSerializationConfig() != null ? config
                    .getSerializationConfig() : new SerializationConfig();
            ss = builder.setClassLoader(configClassLoader)
                    .setConfig(serializationConfig)
                    .setManagedContext(new HazelcastClientManagedContext(client, config.getManagedContext()))
                    .setPartitioningStrategy(partitioningStrategy)
                    .setHazelcastInstance(hazelcastInstance)
                    .build();
        } catch (Exception e) {
            throw ExceptionUtil.rethrow(e);
View Full Code Here
TOP

Related Classes of com.hazelcast.client.config.ClientConfig

  • com.hazelcast.client.cache.ClientCacheConfigTest
  • com.hazelcast.client.cache.impl.HazelcastClientCachingProvider
  • com.hazelcast.client.cache.JCacheClientListenerTest
  • com.hazelcast.client.cache.SimpleCacheTestFromClient
  • com.hazelcast.client.ClientEntryListenerDisconnectTest
  • com.hazelcast.client.ClientListenersTest
  • com.hazelcast.client.ClientMemberAttributeTest
  • com.hazelcast.client.ClientNearCacheConfigTest
  • com.hazelcast.client.ClientReconnectTest
  • com.hazelcast.client.ClientRegressionTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.