[jboss-cvs] JBoss Messaging SVN: r3199 - in trunk/src/main/org/jboss/jms: client/remoting and 1 other directories.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2007-10-18 17:27:48 -0400 (Thu, 18 Oct 2007)
New Revision: 3199

Modified:
   trunk/src/main/org/jboss/jms/client/container/ClientConsumer.java
   trunk/src/main/org/jboss/jms/client/remoting/JMSRemotingConnection.java
   trunk/src/main/org/jboss/jms/tx/ResourceManagerFactory.java
Log:
Tweaks


Modified: trunk/src/main/org/jboss/jms/client/container/ClientConsumer.java
===================================================================
--- trunk/src/main/org/jboss/jms/client/container/ClientConsumer.java	2007-10-18 16:40:51 UTC (rev 3198)
+++ trunk/src/main/org/jboss/jms/client/container/ClientConsumer.java	2007-10-18 21:27:48 UTC (rev 3199)
@@ -872,7 +872,7 @@
                 if (token != currentToken)
                 {
                	 //This message was queued up from before failover - we don't want to add it
-               	 log.info("Ignoring message " + message);
+               	 log.trace("Ignoring message " + message);
                	 return;
                 }
                 

Modified: trunk/src/main/org/jboss/jms/client/remoting/JMSRemotingConnection.java
===================================================================
--- trunk/src/main/org/jboss/jms/client/remoting/JMSRemotingConnection.java	2007-10-18 16:40:51 UTC (rev 3198)
+++ trunk/src/main/org/jboss/jms/client/remoting/JMSRemotingConnection.java	2007-10-18 21:27:48 UTC (rev 3199)
@@ -126,6 +126,17 @@
             metadata.put(Client.CALLBACK_SERVER_PORT, propertyPort);
          }
          
+         Map params = serverLocator.getParameters();
+         int maxPoolSize = 50;
+         if (params != null)
+         {
+         	String val = (String)params.get(MicroSocketClientInvoker.MAX_POOL_SIZE_FLAG);
+         	maxPoolSize = Integer.valueOf((String)val).intValue();
+         }
+         
+         //Use the same value for the callback server
+         metadata.put(MicroSocketClientInvoker.MAX_POOL_SIZE_FLAG, String.valueOf(maxPoolSize));
+         
          String protocol = serverLocator.getProtocol();
          if ("bisocket".equals(protocol) || "sslbisocket".equals(protocol))
          {

Modified: trunk/src/main/org/jboss/jms/tx/ResourceManagerFactory.java
===================================================================
--- trunk/src/main/org/jboss/jms/tx/ResourceManagerFactory.java	2007-10-18 16:40:51 UTC (rev 3198)
+++ trunk/src/main/org/jboss/jms/tx/ResourceManagerFactory.java	2007-10-18 21:27:48 UTC (rev 3199)
@@ -159,15 +159,15 @@
    
    public void dump()
    {
-   	log.info("Dumping " + this);
+   	log.debug("Dumping " + this);
    	Iterator iter = holders.entrySet().iterator();
    	while (iter.hasNext())
    	{
    		Map.Entry entry = (Map.Entry)iter.next();
    		
-   		log.info(entry.getKey() + "--->" + entry.getValue());
+   		log.debug(entry.getKey() + "--->" + entry.getValue());
    	}
-   	log.info("End dump");
+   	log.debug("End dump");
    }
 
    // Package protected ----------------------------------------------------------------------------