org.robokind.impl.messaging.utils
Class JMSAvroPolymorphicRecordBytesAdapter<Msg>
java.lang.Object
org.robokind.impl.messaging.utils.JMSAvroPolymorphicRecordBytesAdapter<Msg>
- All Implemented Interfaces:
- org.jflux.api.core.Adapter<Msg,javax.jms.BytesMessage>
public class JMSAvroPolymorphicRecordBytesAdapter<Msg>
- extends Object
- implements org.jflux.api.core.Adapter<Msg,javax.jms.BytesMessage>
- Author:
- Matthew Stevenson
Method Summary |
javax.jms.BytesMessage |
adapt(Msg a)
|
<R extends org.apache.avro.generic.IndexedRecord>
void |
|
addAdapter(org.jflux.api.core.Adapter<Msg,R> adapter,
String contentType)
|
void |
setSession(javax.jms.Session session)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMSAvroPolymorphicRecordBytesAdapter
public JMSAvroPolymorphicRecordBytesAdapter(org.robokind.api.common.utils.PolymorphicAdapter.AdapterKeyMap<Msg> keyMap)
setSession
public void setSession(javax.jms.Session session)
addAdapter
public <R extends org.apache.avro.generic.IndexedRecord> void addAdapter(org.jflux.api.core.Adapter<Msg,R> adapter,
String contentType)
adapt
public javax.jms.BytesMessage adapt(Msg a)
- Specified by:
adapt
in interface org.jflux.api.core.Adapter<Msg,javax.jms.BytesMessage>
Copyright © 2011-2013. All Rights Reserved.