[hornetq-commits] JBoss hornetq SVN: r10975 - branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/client/impl.

do-not-reply at jboss.org do-not-reply at jboss.org
Wed Jul 13 11:32:11 EDT 2011


Author: borges
Date: 2011-07-13 11:32:11 -0400 (Wed, 13 Jul 2011)
New Revision: 10975

Modified:
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java
Log:
spelling

Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java	2011-07-13 15:31:38 UTC (rev 10974)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java	2011-07-13 15:32:11 UTC (rev 10975)
@@ -111,7 +111,7 @@
 
    // Attributes ----------------------------------------------------------------------------
 
-   private Map<String, String> metadata = new HashMap<String, String>();
+   private final Map<String, String> metadata = new HashMap<String, String>();
 
    private final ClientSessionFactoryInternal sessionFactory;
 
@@ -445,13 +445,13 @@
    }
 
    /*
-    * Note, we DO NOT currently support direct consumers (i.e. consumers we're delivery occurs on the remoting thread.
-    * Direct consumers have issues with blocking and failover.
-    * E.g. if direct then inside MessageHandler call a blocking method like rollback or acknowledge (blocking)
-    * This can block until failove completes, which disallows the thread to be used to deliver any responses to the client
-    * during that period, so failover won't occur.
-    * If we want direct consumers we need to rethink how they work
-   */
+    * Note, we DO NOT currently support direct consumers (i.e. consumers we're delivery occurs on
+    * the remoting thread. Direct consumers have issues with blocking and failover. E.g. if direct
+    * then inside MessageHandler call a blocking method like rollback or acknowledge (blocking) This
+    * can block until failover completes, which disallows the thread to be used to deliver any
+    * responses to the client during that period, so failover won't occur. If we want direct
+    * consumers we need to rethink how they work
+    */
    public ClientConsumer createConsumer(final SimpleString queueName,
                                         final SimpleString filterString,
                                         final int windowSize,
@@ -1606,7 +1606,8 @@
    {
       return remotingConnection;
    }
-   
+
+   @Override
    public String toString()
    {
       StringBuffer buffer = new StringBuffer();



More information about the hornetq-commits mailing list