- public void metadataUpdated(Metadata metadata) {
- this.metadata = metadata;
- fireMetadataUpdated(metadata);
- eventBus.post(new MetadataUpdated(this, metadata));
- }
-
- @Override
- public void process(byte[] buffer) throws IOException {
- fileOutputStream.write(buffer);
- logger.finest(String.format("FileSink: Wrote %d Bytes.", buffer.length));
+ public void process(DataPacket dataPacket) throws IOException {
+ fileOutputStream.write(dataPacket.buffer());
+ logger.finest(String.format("FileSink: Wrote %d Bytes.", dataPacket.buffer().length));