[hornetq-commits] JBoss hornetq SVN: r10005 - trunk/src/main/org/hornetq/utils.

Author: clebert.suconic(a)jboss.com Date: 2010-12-06 23:33:00 -0500 (Mon, 06 Dec 2010) New Revision: 10005 Modified: trunk/src/main/org/hornetq/utils/InflaterWriter.java Log: just cleanup imports Modified: trunk/src/main/org/hornetq/utils/InflaterWriter.java =================================================================== --- trunk/src/main/org/hornetq/utils/InflaterWriter.java 2010-12-07 04:22:51 UTC (rev 10004) +++ trunk/src/main/org/hornetq/utils/InflaterWriter.java 2010-12-07 04:33:00 UTC (rev 10005) @@ -13,12 +13,9 @@ package org.hornetq.utils; -import java.io.ByteArrayInputStream; -import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.OutputStream; import java.util.zip.DataFormatException; -import java.util.zip.Deflater; import java.util.zip.Inflater; /** @@ -35,15 +32,17 @@ */ public class InflaterWriter extends OutputStream { - private Inflater inflater = new Inflater(); - private OutputStream output; - - private byte[] writeBuffer = new byte[1024]; + private final Inflater inflater = new Inflater(); + + private final OutputStream output; + + private final byte[] writeBuffer = new byte[1024]; + private int writePointer = 0; - - private byte[] outputBuffer = new byte[writeBuffer.length*2]; - - public InflaterWriter(OutputStream output) + + private final byte[] outputBuffer = new byte[writeBuffer.length * 2]; + + public InflaterWriter(final OutputStream output) { this.output = output; } @@ -52,11 +51,11 @@ * Write a compressed byte. */ @Override - public void write(int b) throws IOException + public void write(final int b) throws IOException { writeBuffer[writePointer] = (byte)(b & 0xFF); writePointer++; - + if (writePointer == writeBuffer.length) { writePointer = 0; @@ -70,7 +69,7 @@ } } } - + @Override public void close() throws IOException { @@ -93,12 +92,12 @@ } } } - + private void doWrite() throws DataFormatException, IOException { inflater.setInput(writeBuffer); int n = inflater.inflate(outputBuffer); - + while (n > 0) { output.write(outputBuffer, 0, n);