@Test
public void testRetrieveProduct() throws DataTransferException, IOException {

	dataTransferer.retrieveProduct(product, stagingDir);
	ArgumentCaptor<GetObjectRequest> argument = ArgumentCaptor.forClass(GetObjectRequest.class);
	verify(s3Client).getObject(argument.capture());
	GetObjectRequest request = argument.getValue();
	assertThat(request.getBucketName(), is(S3_BUCKET_NAME));
	assertThat(request.getKey(), is(EXPECTED_DATA_STORE_REF));
}