[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