org.robokind.impl.messaging.utils
Class JMSAvroPolymorphicBytesRecordAdapter<Msg>

java.lang.Object
  extended by org.robokind.impl.messaging.utils.JMSAvroPolymorphicBytesRecordAdapter<Msg>
All Implemented Interfaces:
org.jflux.api.core.Adapter<javax.jms.BytesMessage,Msg>

public class JMSAvroPolymorphicBytesRecordAdapter<Msg>
extends Object
implements org.jflux.api.core.Adapter<javax.jms.BytesMessage,Msg>

Author:
Matthew Stevenson

Nested Class Summary
 class JMSAvroPolymorphicBytesRecordAdapter.JMSAvroBytesRecordAdapter<Rec extends org.apache.avro.generic.IndexedRecord>
           
 
Constructor Summary
JMSAvroPolymorphicBytesRecordAdapter()
           
 
Method Summary
 Msg adapt(javax.jms.BytesMessage a)
           
<R extends org.apache.avro.generic.IndexedRecord>
void
addAdapter(Class<R> recordClass, org.apache.avro.Schema recordSchema, org.jflux.api.core.Adapter<R,Msg> adapter, String contentType)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JMSAvroPolymorphicBytesRecordAdapter

public JMSAvroPolymorphicBytesRecordAdapter()
Method Detail

addAdapter

public <R extends org.apache.avro.generic.IndexedRecord> void addAdapter(Class<R> recordClass,
                                                                         org.apache.avro.Schema recordSchema,
                                                                         org.jflux.api.core.Adapter<R,Msg> adapter,
                                                                         String contentType)

adapt

public Msg adapt(javax.jms.BytesMessage a)
Specified by:
adapt in interface org.jflux.api.core.Adapter<javax.jms.BytesMessage,Msg>


Copyright © 2011-2013. All Rights Reserved.