org.robokind.impl.messaging.utils
Class JMSAvroPolymorphicBytesRecordAdapter<Msg>
java.lang.Object
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
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 |
JMSAvroPolymorphicBytesRecordAdapter
public JMSAvroPolymorphicBytesRecordAdapter()
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.