org.robokind.impl.messaging
Class JMSMessageReceiver<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>
java.lang.Object
org.robokind.api.messaging.DefaultMessageReceiver<Msg,Rec,L>
org.robokind.impl.messaging.JMSMessageReceiver<Msg,Rec,L>
- All Implemented Interfaces:
- org.robokind.api.messaging.MessageReceiver<Msg,Rec,L>
public class JMSMessageReceiver<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>
- extends org.robokind.api.messaging.DefaultMessageReceiver<Msg,Rec,L>
A DefaultMessageReceiver for receiving Avro Records over JMS (Qpid).
- Author:
- Matthew Stevenson
Constructor Summary |
JMSMessageReceiver(javax.jms.Session session,
javax.jms.Destination destination,
Class<Rec> recordClass,
org.apache.avro.Schema recordSchema)
Creates a new JMSMessageReceiver |
Method Summary |
void |
start()
Start the JMSMessageReceiver receiving Message. |
Methods inherited from class org.robokind.api.messaging.DefaultMessageReceiver |
addMessageListener, fireMessageEvent, pause, removeMessageListener, resume, setAdapter, setRecordReceiver, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMSMessageReceiver
public JMSMessageReceiver(javax.jms.Session session,
javax.jms.Destination destination,
Class<Rec> recordClass,
org.apache.avro.Schema recordSchema)
- Creates a new JMSMessageReceiver
- Parameters:
session
- the JMS Session to use for receivingdestination
- the JMS Destination to receive fromrecordClass
- the Class of the Avro Record being receivedrecordSchema
- the Avro Schema of the Record being received
start
public void start()
throws javax.jms.JMSException,
Exception
- Start the JMSMessageReceiver receiving Message.
Creates and starts a JMSRecordReceiver to receive Records.
- Specified by:
start
in interface org.robokind.api.messaging.MessageReceiver<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>
- Overrides:
start
in class org.robokind.api.messaging.DefaultMessageReceiver<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>
- Throws:
javax.jms.JMSException
- if there is an error creating a JMS MessageConsumer
or starting the JMS Polling Service.
Exception
- inherited throws statement, should not throw Exception
Copyright © 2011. All Rights Reserved.