tst/com/amazon/kinesis/streaming/agent/tailing/KinesisParserTest.java [49:60]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private AgentContext getTestKinesisAgentContext() {
    	Map<String, Object> config = new HashMap<>();
    	List<Configuration> flows = new ArrayList<>();
    	Map<String, Object> flow = new HashMap<>();
        flow.put("filePattern", "/var/log/message.log*");
        flow.put(KinesisConstants.DESTINATION_KEY, RandomStringUtils.randomAlphabetic(5));
        flows.add(new Configuration(flow));
        config.put("flows", flows);
        config.put("checkpointFile", globalTestFiles.getTempFilePath());
        config.put("cloudwatch.emitMetrics", false);
        return TestUtils.getTestAgentContext(config);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/KinesisSenderTest.java [193:204]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private AgentContext getTestKinesisAgentContext() {
    	Map<String, Object> config = new HashMap<>();
    	List<Configuration> flows = new ArrayList<>();
    	Map<String, Object> flow = new HashMap<>();
        flow.put("filePattern", "/var/log/message.log*");
        flow.put(KinesisConstants.DESTINATION_KEY, RandomStringUtils.randomAlphabetic(5));
        flows.add(new Configuration(flow));
        config.put("flows", flows);
        config.put("checkpointFile", globalTestFiles.getTempFilePath());
        config.put("cloudwatch.emitMetrics", false);
        return TestUtils.getTestAgentContext(config);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -