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

java.lang.Object
  extended by 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

Nested Class Summary
static class JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter<A extends org.apache.avro.generic.IndexedRecord>
           
 
Constructor Summary
JMSAvroPolymorphicRecordBytesAdapter(org.robokind.api.common.utils.PolymorphicAdapter.AdapterKeyMap<Msg> keyMap)
           
 
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
 

Constructor Detail

JMSAvroPolymorphicRecordBytesAdapter

public JMSAvroPolymorphicRecordBytesAdapter(org.robokind.api.common.utils.PolymorphicAdapter.AdapterKeyMap<Msg> keyMap)
Method Detail

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.