	@Test
	public void shouldCreateClusterWithConfig() throws Exception {


		CassandraServiceInfo info = new CassandraServiceInfo("local",
				Collections.singletonList("127.0.0.1"), 9142);

		CassandraClusterConfig config = new CassandraClusterConfig();
		config.setCompression(ProtocolOptions.Compression.NONE);
		config.setPoolingOptions(new PoolingOptions().setPoolTimeoutMillis(1234));
		config.setQueryOptions(new QueryOptions());
		config.setProtocolVersion(ProtocolVersion.NEWEST_SUPPORTED);
		config.setLoadBalancingPolicy(new RoundRobinPolicy());
		config.setReconnectionPolicy(new ConstantReconnectionPolicy(1));
		config.setRetryPolicy(DowngradingConsistencyRetryPolicy.INSTANCE);
		config.setSocketOptions(new SocketOptions());

		Cluster cluster = creator.create(info, config);

		Configuration configuration = cluster.getConfiguration();

		assertThat(configuration.getProtocolOptions().getCompression(),
				is(config.getCompression()));
		assertThat(configuration.getQueryOptions(), is(config.getQueryOptions()));
		assertThat(configuration.getSocketOptions(), is(config.getSocketOptions()));

		Policies policies = configuration.getPolicies();
		assertThat(policies.getLoadBalancingPolicy(),
				is(config.getLoadBalancingPolicy()));
		assertThat(policies.getReconnectionPolicy(), is(config.getReconnectionPolicy()));
		assertThat(policies.getRetryPolicy(), is(config.getRetryPolicy()));
	}