svn commit: r515193 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java

[jstrachan]

Author: jstrachan
Date: Tue Mar  6 08:31:46 2007
New Revision: 515193

URL: http://svn.apache.org/viewvc?view=rev&rev=515193
Log:
minor fix to avoid exception in some test cases

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?view=diff&rev=515193&r1=515192&r2=515193
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
 Tue Mar  6 08:31:46 2007
@@ -1447,6 +1447,9 @@
     }
 
     public BlobTransferPolicy getBlobTransferPolicy() {
+        if (blobTransferPolicy == null) {
+            blobTransferPolicy = createBlobTransferPolicy();
+        }
         return blobTransferPolicy;
     }
 
@@ -1981,5 +1984,9 @@
     
     public String toString() {
         return "ActiveMQConnection 
{id="+info.getConnectionId()+",clientId="+info.getClientId()+",started="+started.get()+"}";
-    }    
+    }
+
+    protected BlobTransferPolicy createBlobTransferPolicy() {
+        return new BlobTransferPolicy();
+    }
 }