+ public void process(DataPacket dataPacket) throws IOException {
+ if (dataPacket.metadata().isPresent() && !dataPacket.metadata().get().equalsIgnoreComment(this.metadata.get())) {
+ metadataUpdated(dataPacket.metadata().get());
+ }
+ logger.finest(String.format("Writing %d bytes to %s...", dataPacket.buffer().length, name()));
+ outputStream.write(dataPacket.buffer());