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
  extended by org.robokind.api.messaging.DefaultMessageReceiver<Msg,Rec,L>
      extended by 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
 

Constructor Detail

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 receiving
destination - the JMS Destination to receive from
recordClass - the Class of the Avro Record being received
recordSchema - the Avro Schema of the Record being received
Method Detail

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.