Async ID client

Async ID client implementation for id services such as Flurry Unique id generation service. It's based on a producer-consumer pattern. A thread pool constantly fetches new ids and keeps them in a local queue.

Compatibility

• Java 6+
• Supported clients
  • Flurry v0.2.0-beta

Dependency

<dependency>
    <groupId>com.hubrick.client</groupId>
    <artifactId>id-client</artifactId>
    <version>1.0.0</version>
</dependency>

Features

• Flurry
  • Id collision protection (If the servers are misconfiguration and have the same workerId a collision can occur. The client checks the configuration on startup.)
  • Automated reconnection to servers (If a server was down and shows up again the client will automatically reconnect and start to consume the ids again)

How to use

###Create an instance

public IdClient createClient() {
	return new FlurryIdClient.Builder()
		.addServiceEndpoint("localhost", 9090)
		.addServiceEndpoint("localhost", 9091)
		.addServiceEndpoint("localhost", 9092)
		.withQueueSize(1000)
		.withThreadPoolSize(10)
		.withWaitOnFailMillis(1000)
		.build();
    }

###Consume ids

public void someMethod(IdClient idClient) {
	try {
		System.out.println("Retrieved id in a blocking way. ID: " + idClient.getId());	
		System.out.println("Retrieved id in a blocking way wit timeout. ID: " + idClient.getId(100));	
	} catch (InterruptedException e) {
		// Should not happen
	}
	
	System.out.println("Retrieved id in a non blocking way. ID: " + idClient.getIdNonBlocking());	
}

Exceptions

License

Apache License, Version 2.0