MemorycraftKinesisLoggingProcessorFactory.java

import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor;
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory;

/**
 * Used to create new record processors.
 */
public class MemorycraftKinesisLoggingProcessorFactory implements IRecordProcessorFactory {

    /**
     * Constructor.
     */
    public MemorycraftKinesisLoggingProcessorFactory() {
        super();
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public IRecordProcessor createProcessor() {
        return new MemorycraftKinesisLoggingProcessor();
    }

}