org.robokind.impl.messaging.utils
Class JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter<A extends org.apache.avro.generic.IndexedRecord>

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

public static class JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter<A extends org.apache.avro.generic.IndexedRecord>
extends Object
implements org.jflux.api.core.Adapter<A,javax.jms.BytesMessage>


Constructor Summary
JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter(org.jflux.api.core.Source<org.apache.qpid.client.message.JMSBytesMessage> messageFactory, String contentType)
           
 
Method Summary
 javax.jms.BytesMessage adapt(A a)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter

public JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter(org.jflux.api.core.Source<org.apache.qpid.client.message.JMSBytesMessage> messageFactory,
                                                                      String contentType)
Method Detail

adapt

public javax.jms.BytesMessage adapt(A a)
Specified by:
adapt in interface org.jflux.api.core.Adapter<A extends org.apache.avro.generic.IndexedRecord,javax.jms.BytesMessage>


Copyright © 2011-2013. All Rights Reserved.