Package com.hazelcast.client.config

Examples of com.hazelcast.client.config.ClientConfig

29
30
31
32
33
34
35
36
37
38
    @Before
    public void init() {
        cluster = new SimpleClusterUtil("A", 3);
        cluster.initCluster();

        ClientConfig clientConfig = new ClientConfig();
        clientConfig.setGroupConfig(new GroupConfig(cluster.getName()));
        client1 = HazelcastClient.newHazelcastClient(clientConfig);
        client2 = HazelcastClient.newHazelcastClient(clientConfig);
    }
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
    @BeforeClass
    public static void setup() throws Exception {
        h1 = Hazelcast.newHazelcastInstance();
        h2 = Hazelcast.newHazelcastInstance();

        ClientConfig clientConfig = new ClientConfig();

        NearCacheConfig basicConfigNoInvalidation = new NearCacheConfig();
        basicConfigNoInvalidation.setInMemoryFormat(InMemoryFormat.OBJECT);
        basicConfigNoInvalidation.setName(NEAR_CACHE_WITH_NO_INVALIDATION + "*");
        basicConfigNoInvalidation.setInvalidateOnChange(false);
        clientConfig.addNearCacheConfig(basicConfigNoInvalidation);

        NearCacheConfig maxSizeConfig = new NearCacheConfig();
        maxSizeConfig.setMaxSize(MAX_CACHE_SIZE);
        maxSizeConfig.setInvalidateOnChange(false);
        maxSizeConfig.setName(NEAR_CACHE_WITH_MAX_SIZE + "*");
        clientConfig.addNearCacheConfig(maxSizeConfig);

        NearCacheConfig ttlConfig = new NearCacheConfig();
        ttlConfig.setName(NEAR_CACHE_WITH_TTL + "*");
        ttlConfig.setInvalidateOnChange(false);
        ttlConfig.setTimeToLiveSeconds(MAX_TTL_SECONDS);
        clientConfig.addNearCacheConfig(ttlConfig);

        NearCacheConfig idleConfig = new NearCacheConfig();
        idleConfig.setName(NEAR_CACHE_WITH_IDLE + "*");
        idleConfig.setInvalidateOnChange(false);
        idleConfig.setMaxIdleSeconds(MAX_IDLE_SECONDS);
        clientConfig.addNearCacheConfig(idleConfig);

        NearCacheConfig invalidateConfig = new NearCacheConfig();
        invalidateConfig.setName(NEAR_CACHE_WITH_INVALIDATION + "*");
        invalidateConfig.setInvalidateOnChange(true);
        clientConfig.addNearCacheConfig(invalidateConfig);

        client = HazelcastClient.newHazelcastClient(clientConfig);
    }
View Full Code Here
1640
1641
1642
1643
1644
1645
1646
1647
1648
1649
1650
1651
1652
1653
1654
1655
     *
     * @param args none
     * @throws Exception
     */
    public static void main(String[] args) throws Exception {
        ClientConfig clientConfig;

        try {
            clientConfig = new XmlClientConfigBuilder("hazelcast-client.xml").build();
        } catch (IllegalArgumentException e) {
            clientConfig = new ClientConfig();
        }
        final HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);
        ClientConsoleApp clientConsoleApp = new ClientConsoleApp(client);
        clientConsoleApp.start(args);
    }
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
        IMap<Integer, GenericEvent> map = hazelcastInstance.getMap("test");
        map.addIndex("userId", false);

        Hazelcast.newHazelcastInstance(config);

        ClientConfig clientConfig = new ClientConfig();
        clientConfig.getNetworkConfig().addAddress("localhost:6701", "localhost:6702");
        clientConfig.setGroupConfig(new GroupConfig("test", "test"));
        clientConfig.getNetworkConfig().setConnectionAttemptLimit(100);
        clientConfig.getNetworkConfig().setSmartRouting(false);

        HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);
        IMap<Integer, GenericEvent> mapClient = client.getMap("test");

        mapClient.addEntryListener(new EntryAdapter<Integer, GenericEvent>() {
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
105
                configURL = uri.toURL();
            } else {
                throw new URISyntaxException(location, "Unsupported protocol in configuration location URL");
            }
            try {
                final ClientConfig config = new XmlClientConfigBuilder(configURL).build();
                config.setClassLoader(theClassLoader);
                instance = HazelcastClient.newHazelcastClient(config);
            } catch (Exception e) {
                throw ExceptionUtil.rethrow(e);
            }
        }
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
@Category(QuickTest.class)
public class ClientNearCacheConfigTest {

    @Test
    public void testSpecificNearCacheConfig_whenAsteriskAtTheEnd(){
        final ClientConfig clientConfig = new ClientConfig();
        final NearCacheConfig genericNearCacheConfig = new NearCacheConfig();
        genericNearCacheConfig.setName("map*");
        clientConfig.addNearCacheConfig(genericNearCacheConfig);

        final NearCacheConfig specificNearCacheConfig = new NearCacheConfig();
        specificNearCacheConfig.setName("mapStudent*");
        clientConfig.addNearCacheConfig(specificNearCacheConfig);

        final NearCacheConfig mapFoo = clientConfig.getNearCacheConfig("mapFoo");
        final NearCacheConfig mapStudentFoo = clientConfig.getNearCacheConfig("mapStudentFoo");

        assertEquals(genericNearCacheConfig, mapFoo);
        assertEquals(specificNearCacheConfig, mapStudentFoo);
    }
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
        assertEquals(specificNearCacheConfig, mapStudentFoo);
    }

    @Test
    public void testSpecificNearCacheConfig_whenAsteriskAtTheBeginning(){
        final ClientConfig clientConfig = new ClientConfig();
        final NearCacheConfig genericNearCacheConfig = new NearCacheConfig();
        genericNearCacheConfig.setName("*Map");
        clientConfig.addNearCacheConfig(genericNearCacheConfig);

        final NearCacheConfig specificNearCacheConfig = new NearCacheConfig();
        specificNearCacheConfig.setName("*MapStudent");
        clientConfig.addNearCacheConfig(specificNearCacheConfig);

        final NearCacheConfig mapFoo = clientConfig.getNearCacheConfig("fooMap");
        final NearCacheConfig mapStudentFoo = clientConfig.getNearCacheConfig("fooMapStudent");

        assertEquals(genericNearCacheConfig, mapFoo);
        assertEquals(specificNearCacheConfig, mapStudentFoo);
    }
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
        assertEquals(specificNearCacheConfig, mapStudentFoo);
    }

    @Test
    public void testSpecificNearCacheConfig_whenAsteriskInTheMiddle(){
        final ClientConfig clientConfig = new ClientConfig();
        final NearCacheConfig genericNearCacheConfig = new NearCacheConfig();
        genericNearCacheConfig.setName("map*Bar");
        clientConfig.addNearCacheConfig(genericNearCacheConfig);

        final NearCacheConfig specificNearCacheConfig = new NearCacheConfig();
        specificNearCacheConfig.setName("mapStudent*Bar");
        clientConfig.addNearCacheConfig(specificNearCacheConfig);

        final NearCacheConfig mapFoo = clientConfig.getNearCacheConfig("mapFooBar");
        final NearCacheConfig mapStudentFoo = clientConfig.getNearCacheConfig("mapStudentFooBar");

        assertEquals(genericNearCacheConfig, mapFoo);
        assertEquals(specificNearCacheConfig, mapStudentFoo);
    }
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
136
    public ClientConnectionManagerImpl(HazelcastClientInstanceImpl client,
                                       LoadBalancer loadBalancer,
                                       AddressTranslator addressTranslator) {
        this.client = client;
        this.addressTranslator = addressTranslator;
        final ClientConfig config = client.getClientConfig();
        final ClientNetworkConfig networkConfig = config.getNetworkConfig();

        final int connTimeout = networkConfig.getConnectionTimeout();
        connectionTimeout = connTimeout == 0 ? Integer.MAX_VALUE : connTimeout;

        final ClientProperties clientProperties = client.getClientProperties();
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
    public static final int STATS_SECONDS = 10;
    public static int GET_PERCENTAGE = 40;
    public static int PUT_PERCENTAGE = 40;

    public static void main(String[] args) {
        final ClientConfig clientConfig = new ClientConfig();
        final HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
        final HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
        final HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);
        final Stats stats = new Stats();
        if (args != null && args.length > 0) {
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.