package com.trendmicro.grid.acl.ds.cache.commands;
   
   import org.aspectj.lang.ProceedingJoinPoint;
   
   import java.util.Collection;
   import java.util.Map;
   import java.util.concurrent.atomic.AtomicLong;
   
   /**
   * Returns the values of all keys asking the proceeding join point.
   *
   * @author juergen_kellerer, 2011-03-24
   * @version 1.0
   */
  public class GetFromPJPSourceCommand<K, V> extends GetFromSourceCommand<K, V> {
  
  	private final ProceedingJoinPoint proceedingJoinPoint;
  
  	/**
  	 * Creates the command.
  	 *
  	 * @param keys                the keys to look after.
  	 * @param proceedingJoinPoint the wrapped delegate call.
  	 */
  	public GetFromPJPSourceCommand(AtomicLong fetchedKeyCount, Collection<K> keys, ProceedingJoinPoint proceedingJoinPoint) {
  		super(fetchedKeyCount, keys);
  		this.proceedingJoinPoint = proceedingJoinPoint;
  	}
  
  	@Override
  	public Map<K, V> doCall() throws Exception {
  		try {
  			@SuppressWarnings("unchecked")
  			Collection<V> result = (Collection<V>) proceedingJoinPoint.proceed(new Object[]{keys});
  			return new MapAdapter<K, V>(keys, result);
  		} catch (Exception e) {
  			throw e;
  		} catch (Throwable throwable) {
  			throw new Exception(throwable);
  		}
  	}
  }