Author: mheath
Date: Thu Nov  8 11:49:04 2007
New Revision: 593276

URL: http://svn.apache.org/viewvc?rev=593276&view=rev
Log:
Added utility methods for adding a collection of types per encoder.

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/DemuxingProtocolCodecFactory.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/DemuxingProtocolCodecFactory.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/DemuxingProtocolCodecFactory.java?rev=593276&r1=593275&r2=593276&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/DemuxingProtocolCodecFactory.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/DemuxingProtocolCodecFactory.java
 Thu Nov  8 11:49:04 2007
@@ -19,6 +19,8 @@
  */
 package org.apache.mina.filter.codec.demux;
 
+import java.util.Collection;
+
 import org.apache.mina.filter.codec.ProtocolCodecFactory;
 import org.apache.mina.filter.codec.ProtocolDecoder;
 import org.apache.mina.filter.codec.ProtocolEncoder;
@@ -51,7 +53,7 @@
     }
     
     @SuppressWarnings("unchecked")
-    public void addMessageEncoder(Class<?> messageType, Class<? extends 
MessageEncoder> encoderClass) {
+    public <T> void addMessageEncoder(Class<T> messageType, Class<? extends 
MessageEncoder<? super T>> encoderClass) {
         this.encoder.addMessageEncoder(messageType, encoderClass);
     }
 
@@ -62,7 +64,25 @@
     public <T> void addMessageEncoder(Class<T> messageType, 
MessageEncoderFactory<? super T> factory) {
         this.encoder.addMessageEncoder(messageType, factory);
     }
-
+    
+    public <T> void addMessageEncoder(Collection<Class<? extends T>> 
messageTypes, Class<? extends MessageEncoder<? super T>> encoderClass) {
+       for (Class<? extends T> messageType : messageTypes) {
+               this.encoder.addMessageEncoder(messageType, encoderClass);
+       }
+    }
+    
+    public <T> void addMessageEncoder(Collection<Class<? extends T>> 
messageTypes, MessageEncoder<? super T> encoder) {
+       for (Class<? extends T> messageType : messageTypes) {
+               this.encoder.addMessageEncoder(messageType, encoder);
+       }
+    }
+    
+    public <T> void addMessageEncoder(Collection<Class<? extends T>> 
messageTypes, MessageEncoderFactory<? super T> factory) {
+       for (Class<? extends T> messageType : messageTypes) {
+               this.encoder.addMessageEncoder(messageType, factory);
+       }
+    }
+    
     public void addMessageDecoder(Class<? extends MessageDecoder> 
decoderClass) {
         this.decoder.addMessageDecoder(decoderClass);
     }


Reply via email to