Author: gaohoward
Date: 2010-11-12 01:51:54 -0500 (Fri, 12 Nov 2010)
New Revision: 9880
Modified:
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/DecompressedLargeMessageBuffer.java
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/GZipUtil.java
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/HornetQBufferInputStream.java
Log:
added a convenient method for creating GZIPInputStream
Modified:
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/DecompressedLargeMessageBuffer.java
===================================================================
---
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/DecompressedLargeMessageBuffer.java 2010-11-12
05:23:35 UTC (rev 9879)
+++
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/DecompressedLargeMessageBuffer.java 2010-11-12
06:51:54 UTC (rev 9880)
@@ -162,7 +162,7 @@
{
InputStream input = new HornetQBufferInputStream(bufferDelegate);
- dataInput = new DataInputStream(GZipUtil.pipeGZip(input, false,
threadPool));
+ dataInput = new DataInputStream(GZipUtil.createUnZipInputStream(input));
}
catch (Exception e)
{
Modified:
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/GZipUtil.java
===================================================================
---
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/GZipUtil.java 2010-11-12
05:23:35 UTC (rev 9879)
+++
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/GZipUtil.java 2010-11-12
06:51:54 UTC (rev 9880)
@@ -179,6 +179,18 @@
throw new HornetQException(HornetQException.LARGE_MESSAGE_ERROR_BODY,
e.getMessage(), e);
}
}
+
+ public static InputStream createUnZipInputStream(InputStream input) throws
HornetQException
+ {
+ try
+ {
+ return new GZIPInputStream(input);
+ }
+ catch (IOException e)
+ {
+ throw new HornetQException(HornetQException.LARGE_MESSAGE_ERROR_BODY,
e.getMessage(), e);
+ }
+ }
/*
* we keep a list of byte arrays. when writing, we start with the first array.
Modified:
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/HornetQBufferInputStream.java
===================================================================
---
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/HornetQBufferInputStream.java 2010-11-12
05:23:35 UTC (rev 9879)
+++
branches/Branch_Large_Message_Compression/src/main/org/hornetq/utils/HornetQBufferInputStream.java 2010-11-12
06:51:54 UTC (rev 9880)
@@ -61,7 +61,7 @@
}
else
{
- return bb.readByte();
+ return bb.readByte() & 0xFF;
}
}