Skip to content

Instantly share code, notes, and snippets.

Revisions

  1. memorycraft created this gist Dec 4, 2013.
    24 changes: 24 additions & 0 deletions MemorycraftKinesisDistanceProcessorFactory.java
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,24 @@
    import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor;
    import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory;

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

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

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

    }