Adelino Rodrigues adelinor

## ConsumerTest.java
package com.github.gist.adelinor.cameljmscalculator.messaging.config;

import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;

import javax.jms.Message;

import org.junit.Ignore;
import org.junit.Test;

## JmsConfig.java
@Configuration
@EnableJms
public class JmsTransactionConfig {

	private static final Logger LOGGER = LoggerFactory.getLogger(JmsTransactionConfig.class);

	@Value("${app.jms.jndi-provider-url}")
	private String jndiProviderUrl;

	@Value("${app.jms.jndi-name}")

## asyncRetry.java
/**
 * Implements a common retry policy for async operations
 * @param fn Async method to retry if necessary
 * @return Result of the function invoked
 */
private <T> ListenableFuture<T> invoke(Function<SharePointFacade, ListenableFuture<T>> fn) {
  // Define an executor with Retry
  RetryExecutor retryExecutor
    = new AsyncRetryExecutor(this.scheduledExecutor)
      .retryOn(AuthenticationExpiredException.class,

## createFileSignature.java
public ListenableFuture<FileSystemItem> createFile(String fileName, boolean overwrite, byte[] content) {
  // ...
}

## listenableFutureBlockingCall.java
futureHandle = asyncMethod();
result = futureHandle.get();
	package com.github.gist.adelinor.cameljmscalculator.messaging.config;

	import static org.junit.Assert.assertFalse;
	import static org.junit.Assert.assertNotNull;
	import static org.junit.Assert.assertTrue;

	import javax.jms.Message;

	import org.junit.Ignore;
	import org.junit.Test;
	@Configuration
	@EnableJms
	public class JmsTransactionConfig {

	private static final Logger LOGGER = LoggerFactory.getLogger(JmsTransactionConfig.class);

	@Value("${app.jms.jndi-provider-url}")
	private String jndiProviderUrl;

	@Value("${app.jms.jndi-name}")
	/**
	* Implements a common retry policy for async operations
	* @param fn Async method to retry if necessary
	* @return Result of the function invoked
	*/
	private <T> ListenableFuture<T> invoke(Function<SharePointFacade, ListenableFuture<T>> fn) {
	// Define an executor with Retry
	RetryExecutor retryExecutor
	= new AsyncRetryExecutor(this.scheduledExecutor)
	.retryOn(AuthenticationExpiredException.class,
	public ListenableFuture<FileSystemItem> createFile(String fileName, boolean overwrite, byte[] content) {
	// ...
	}