CVS update: JGroups/src/org/jgroups/mux Multiplexer.java

"Bela Ban" <[email protected]> Fri, 17 Sep 2010 11:55:26 +0000
Newsgroups gmane.comp.java.javagroups.cvs
Message-ID <[email protected]>
  User: belaban 
  Date: 10/09/17 11:55:26

  Modified:    src/org/jgroups/mux Multiplexer.java
  Log:
  use of Util.createConcurrentMap() instead of new ConcurrentHashMap()
  
  Revision  Changes    Path
  1.114     +5 -5      JGroups/src/org/jgroups/mux/Multiplexer.java
  
  Index: Multiplexer.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/mux/Multiplexer.java,v
  retrieving revision 1.113
  retrieving revision 1.114
  diff -u -r1.113 -r1.114
  --- Multiplexer.java	5 Mar 2010 08:59:12 -0000	1.113
  +++ Multiplexer.java	17 Sep 2010 11:55:26 -0000	1.114
  @@ -1,11 +1,11 @@
   package org.jgroups.mux;
   
  -import org.jgroups.logging.Log;
  -import org.jgroups.logging.LogFactory;
   import org.jgroups.*;
   import org.jgroups.TimeoutException;
  -import org.jgroups.conf.ClassConfigurator;
   import org.jgroups.annotations.Experimental;
  +import org.jgroups.conf.ClassConfigurator;
  +import org.jgroups.logging.Log;
  +import org.jgroups.logging.LogFactory;
   import org.jgroups.protocols.pbcast.FLUSH;
   import org.jgroups.stack.StateTransferInfo;
   import org.jgroups.util.*;
  @@ -37,7 +37,7 @@
    * @author Bela Ban, Vladimir Blagojevic
    * @see MuxChannel
    * @see Channel
  - * @version $Id: Multiplexer.java,v 1.113 2010/03/05 08:59:12 belaban Exp $
  + * @version $Id: Multiplexer.java,v 1.114 2010/09/17 11:55:26 belaban Exp $
    */
   @Experimental(comment="because of impedance mismatches between a MuxChannel and JChannel, this might get deprecated " +
           "in the future. The replacement would be a shared transport (see the documentation for details)")
  @@ -53,7 +53,7 @@
        * Map<String,MuxChannel>. Maintains the mapping between service IDs and
        * their associated MuxChannels
        */
  -    private final ConcurrentMap<String,MuxChannel> services=new ConcurrentHashMap<String,MuxChannel>();
  +    private final ConcurrentMap<String, MuxChannel> services=Util.createConcurrentMap();
       private final JChannel channel;
   
       /** Thread pool to concurrently process messages sent to different services */
  
  
  

------------------------------------------------------------------------------
Start uncovering the many advantages of virtual appliances
and start using them to simplify application deployment and
accelerate your shift to cloud computing.
http://p.sf.net/sfu/novell-sfdev2dev