org.robokind.impl.messaging.utils
Class JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter<A extends org.apache.avro.generic.IndexedRecord>
java.lang.Object
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>
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 |
JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter
public JMSAvroPolymorphicRecordBytesAdapter.JMSAvroRecordBytesAdapter(org.jflux.api.core.Source<org.apache.qpid.client.message.JMSBytesMessage> messageFactory,
String contentType)
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.