[hornetq-commits] JBoss hornetq SVN: r8516 - trunk/src/main/org/hornetq/core/server/impl.
Author: jmesnil
Date: 2009-12-03 03:29:30 -0500 (Thu, 03 Dec 2009)
New Revision: 8516
Modified:
trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java
Log:
factorized ServerSessionImpl.getCreditManagerHolder() methods
Modified: trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java 2009-12-03 07:25:42
UTC (rev 8515)
+++ trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java 2009-12-03 08:29:30
UTC (rev 8516)
@@ -23,8 +23,6 @@
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executor;
-import java.util.concurrent.Executors;
-import java.util.concurrent.LinkedBlockingQueue;
import javax.transaction.xa.XAException;
import javax.transaction.xa.XAResource;
@@ -1901,29 +1899,13 @@
*/
private void releaseOutStanding(final ServerMessage message, final int credits) throws
Exception
{
- CreditManagerHolder holder = getCreditManagerHolder(message);
+ CreditManagerHolder holder = getCreditManagerHolder(message.getDestination());
holder.outstandingCredits -= credits;
holder.store.returnProducerCredits(credits);
}
- private CreditManagerHolder getCreditManagerHolder(final ServerMessage message) throws
Exception
- {
- SimpleString address = message.getDestination();
-
- CreditManagerHolder holder = creditManagerHolders.get(address);
-
- if (holder == null)
- {
- holder = new CreditManagerHolder(message.getPagingStore());
-
- creditManagerHolders.put(address, holder);
- }
-
- return holder;
- }
-
private CreditManagerHolder getCreditManagerHolder(final SimpleString address) throws
Exception
{
CreditManagerHolder holder = creditManagerHolders.get(address);