Author: rajdavies
Date: Wed Feb 20 13:47:18 2008
New Revision: 629623
URL: http://svn.apache.org/viewvc?rev=629623&view=rev
Log:
check for null byte passed as parameter
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java?rev=629623&r1=629622&r2=629623&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java
Wed Feb 20 13:47:18 2008
@@ -82,14 +82,16 @@
* @throws IOException
*/
public void write(byte b[], int off, int len) throws IOException {
- if ((bufferlen - count) < len) {
- flush();
- }
- if (buffer.length >= len) {
- System.arraycopy(b, off, buffer, count, len);
- count += len;
- } else {
- out.write(b, off, len);
+ if (b != null) {
+ if ((bufferlen - count) < len) {
+ flush();
+ }
+ if (buffer.length >= len) {
+ System.arraycopy(b, off, buffer, count, len);
+ count += len;
+ } else {
+ out.write(b, off, len);
+ }
}
}