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);
}