activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r515193 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Date Tue, 06 Mar 2007 16:31:47 GMT
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();
+    }
 }



Mime
View raw message