com.caucho.message.encode
Class AmqpDecoder<T>

java.lang.Object
  extended by com.caucho.message.encode.AbstractMessageDecoder<T>
      extended by com.caucho.message.encode.AmqpDecoder<T>
All Implemented Interfaces:
MessageDecoder<T>

public class AmqpDecoder<T>
extends AbstractMessageDecoder<T>

null encoder to ignore messages.


Constructor Summary
AmqpDecoder(AmqpMessageDecoder<T> decoder)
           
 
Method Summary
 T decode(java.io.InputStream is)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AmqpDecoder

public AmqpDecoder(AmqpMessageDecoder<T> decoder)
Method Detail

decode

public T decode(java.io.InputStream is)
         throws java.io.IOException
Throws:
java.io.IOException