@Test void close() { ingester.close(); verify(s3Sender, times(1)).close(); }
@Override public void close() { sender.close(); }
AwsS3Ingester implements Ingester { @Override public void close() { sender.close(); } }
AwsS3Ingester implements Ingester { @Override public void close() { sender.close(); } AwsS3Ingester(AwsS3Sender sender, S3DestinationDecider s3DestinationDecider); }
AwsS3Ingester implements Ingester { @Override public void close() { sender.close(); } AwsS3Ingester(AwsS3Sender sender, S3DestinationDecider s3DestinationDecider); @Override void ingest(String tag, ByteBuffer dataBuffer); @Override Sender getSender(); S3DestinationDecider getS3DestinationDecider(); @Override void close(); }
AwsS3Ingester implements Ingester { @Override public void close() { sender.close(); } AwsS3Ingester(AwsS3Sender sender, S3DestinationDecider s3DestinationDecider); @Override void ingest(String tag, ByteBuffer dataBuffer); @Override Sender getSender(); S3DestinationDecider getS3DestinationDecider(); @Override void close();  }