2024-02-28 12:28:52 -05:00
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
2019-01-23 17:41:21 +00:00
// SPDX-License-Identifier: Apache-2.0
2024-01-16 10:41:11 -05:00
2019-01-23 17:41:21 +00:00
// snippet-start:[dynamodb.java.trydax.DaxAsyncClientDemo] import java.util.HashMap;
import java.util.concurrent.ExecutionException ;
import java.util.concurrent.Future ;
import com.amazon.dax.client.dynamodbv2.ClientConfig ;
import com.amazon.dax.client.dynamodbv2.ClusterDaxAsyncClient ;
import com.amazonaws.auth.profile.ProfileCredentialsProvider ;
import com.amazonaws.handlers.AsyncHandler ;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync ;
import com.amazonaws.services.dynamodbv2.model.AttributeValue ;
import com.amazonaws.services.dynamodbv2.model.GetItemRequest ;
import com.amazonaws.services.dynamodbv2.model.GetItemResult ;
public class DaxAsyncClientDemo {
public static void main ( String [ ] args ) throws Exception {
ClientConfig daxConfig = new ClientConfig ( ) . withCredentialsProvider ( new ProfileCredentialsProvider ( ) )
. withEndpoints ( " mydaxcluster.2cmrwl.clustercfg.dax.use1.cache.amazonaws.com:8111 " ) ;
AmazonDynamoDBAsync client = new ClusterDaxAsyncClient ( daxConfig ) ;
HashMap < String , AttributeValue > key = new HashMap < String , AttributeValue > ( ) ;
key . put ( " Artist " , new AttributeValue ( ) . withS ( " No One You Know " ) ) ;
key . put ( " SongTitle " , new AttributeValue ( ) . withS ( " Scared of My Shadow " ) ) ;
GetItemRequest request = new GetItemRequest ( )
. withTableName ( " Music " ) . withKey ( key ) ;
// Java Futures
Future < GetItemResult > call = client . getItemAsync ( request ) ;
while ( ! call . isDone ( ) ) {
// Do other processing while you're waiting for the response
System . out . println ( " Doing something else for a few seconds... " ) ;
Thread . sleep ( 3000 ) ;
}
// The results should be ready by now
2024-01-16 10:41:11 -05:00
2019-01-23 17:41:21 +00:00
try {
call . get ( ) ;
2024-01-16 10:41:11 -05:00
2019-01-23 17:41:21 +00:00
} catch ( ExecutionException ee ) {
// Futures always wrap errors as an ExecutionException.
// The *real* exception is stored as the cause of the
// ExecutionException
Throwable exception = ee . getCause ( ) ;
System . out . println ( " Error getting item: " + exception . getMessage ( ) ) ;
}
// Async callbacks
call = client . getItemAsync ( request , new AsyncHandler < GetItemRequest , GetItemResult > ( ) {
2024-01-16 10:41:11 -05:00
2019-01-23 17:41:21 +00:00
@Override
public void onSuccess ( GetItemRequest request , GetItemResult getItemResult ) {
System . out . println ( " Result: " + getItemResult ) ;
}
2024-01-16 10:41:11 -05:00
2019-01-23 17:41:21 +00:00
@Override
public void onError ( Exception e ) {
System . out . println ( " Unable to read item " ) ;
System . err . println ( e . getMessage ( ) ) ;
// Callers can also test if exception is an instance of
// AmazonServiceException or AmazonClientException and cast
// it to get additional information
}
2024-01-16 10:41:11 -05:00
2019-01-23 17:41:21 +00:00
} ) ;
call . get ( ) ;
2024-01-16 10:41:11 -05:00
2019-01-23 17:41:21 +00:00
}
}
// snippet-end:[dynamodb.java.trydax.DaxAsyncClientDemo]
