package com.trendmicro.grid.acl.ds.bclog;
   
   import com.trendmicro.grid.acl.ds.ProcessingResultReceiver;
   import com.trendmicro.grid.acl.l0.datatypes.ProcessPackageDataSet;
   import org.slf4j.Logger;
   import org.slf4j.LoggerFactory;
   import org.springframework.stereotype.Service;
   
   import javax.annotation.Resource;
  import java.io.IOException;
  import java.util.Collection;
  
  /**
   * Implements a result receiver that logs all results into a chunked binary log.
   *
   * @author juergen_kellerer, 2010-05-28
   * @version 1.0
   */
  @Service
  public class LoggingProcessingResultReceiver implements ProcessingResultReceiver {
  
  	private static final Logger log = LoggerFactory.getLogger(LoggingProcessingResultReceiver.class);
  
  	@Resource
  	BinaryChangeLogQueue queue;
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public void receive(Collection<ProcessPackageDataSet> dataSets) {
  
  		// TODO: Implement multiplexing to connected ACL nodes in the same GRID site
  
  		for (ProcessPackageDataSet dataSet : dataSets) {
  			try {
  				queue.put(dataSet);
  			} catch (InterruptedException e) {
  				log.warn("TMACL-00670: Caught term signal; Not writing results of job '" +
  						dataSet.getReferringJob() + "' to the binary changelog.");
  				Thread.currentThread().interrupt();
  				return;
  			}
  		}
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public void checkpoint() {
  		try {
  			queue.checkpoint();
  		} catch (InterruptedException e) {
  			Thread.currentThread().interrupt();
  		} catch (IOException e) {
  			log.error("TMACL-00690:Failed to checkpoint the current binary changelog.", e);
  		}
  	}
  }