integration-tests/src/test/java/com/kdgregory/aws/utils/KinesisIntegrationTest.java
/**
     *  Writes a set of messages to the stream. Assumes that all messages can
     *  be sent in a single batch.
     */
Writes a set of messages to the stream. Assumes that all messages can
be sent in a single batch.
Writes a set of messages to the stream . Assumes that all messages can be sent in a single batch .
private void writeMessages(String partitionKey, String message, int count)
    throws Exception
    {
        KinesisWriter writer = new KinesisWriter(client, streamName);
        for (int ii = 0 ; ii < count ; ii++)
        {
            writer.addRecord(partitionKey, message);
        }
        writer.sendAll(2000);
    }
private void writeMessages ( String partitionKey , String message , int count ) throws Exception { KinesisWriter writer = new KinesisWriter ( client , streamName ) ; for ( int ii = 0 ; ii < count ; ii ++ ) { writer . addRecord ( partitionKey , message ) ; } writer . sendAll ( 2000 ) ; }
Writes a set of messages to the stream.
Writes a set of messages to the stream .