tst/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisherServiceTest.java [36:58]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private AgentContext context;
    private FileFlow<FirehoseRecord> flow;

    @SuppressWarnings("unchecked")
    @BeforeMethod
    public void setup() throws IOException {
        context = getTestAgentContext();
        flow = (FileFlow<FirehoseRecord>) context.flows().get(0);
    }

    @DataProvider(name="senders")
    private Object[][] getSendersData() {
        return new Object[][] {
                {new FileSender.PerfectFileSenderFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithHighLatencyFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithPartialFailuresFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithErrorsBeforeCommitFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithPartialFailuresAndErrorsBeforeCommitFactory<FirehoseRecord>()},

                // TODO: The following two senders will produce duplicate records and need the tests need to be modified to handle those
                //{new FileSender.FileSenderWithErrorsAfterPartialCommitFactory<FirehoseRecord>()},
                //{new FileSender.MisbehavingFileSenderFactory<FirehoseRecord>()},
        };
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisherTest.java [36:58]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private AgentContext context;
    private FileFlow<FirehoseRecord> flow;

    @SuppressWarnings("unchecked")
    @BeforeMethod
    public void setup() throws IOException {
        context = getTestAgentContext();
        flow = (FileFlow<FirehoseRecord>) context.flows().get(0);
    }

    @DataProvider(name="senders")
    private Object[][] getSendersData() {
        return new Object[][] {
                {new FileSender.PerfectFileSenderFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithHighLatencyFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithPartialFailuresFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithErrorsBeforeCommitFactory<FirehoseRecord>()},
                {new FileSender.FileSenderWithPartialFailuresAndErrorsBeforeCommitFactory<FirehoseRecord>()},

                // TODO: The following two senders will produce duplicate records and the tests need to be modified to handle those
                //{new FileSender.FileSenderWithErrorsAfterPartialCommitFactory<FirehoseRecord>()},
                //{new FileSender.MisbehavingFileSenderFactory<FirehoseRecord>()},
        };
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -