org.robokind.impl.messaging
Class JMSMessageSender<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.DefaultMessageSender<Msg,Rec,L>
      extended by org.robokind.impl.messaging.JMSMessageSender<Msg,Rec,L>
All Implemented Interfaces:
org.robokind.api.messaging.MessageSender<Msg,Rec,L>

public class JMSMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>
extends org.robokind.api.messaging.DefaultMessageSender<Msg,Rec,L>

DefaultMessageSender for serializing to Avro Records and sending over JMS (Qpid).

Author:
Matthew Stevenson

Field Summary
 
Fields inherited from class org.robokind.api.messaging.DefaultMessageSender
myRecordSender
 
Constructor Summary
JMSMessageSender(javax.jms.Session session, javax.jms.Destination destination, Class<Rec> recordClass)
          Creates a new JMSMessageSender
 
Method Summary
 void start()
          Creates and opens a new JMSRecordSender for sending the Avro Records.
 void stop()
          Closes the JMSRecordReceiver.
 
Methods inherited from class org.robokind.api.messaging.DefaultMessageSender
addMessageListener, fireMessageEvent, removeMessageListener, sendMessage, setAdapter, setRecordSender
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JMSMessageSender

public JMSMessageSender(javax.jms.Session session,
                        javax.jms.Destination destination,
                        Class<Rec> recordClass)
Creates a new JMSMessageSender

Parameters:
session - JMS Session to use for sending
destination - JMS Destination to send to
recordClass - Class of the Avro Record to send
Method Detail

start

public void start()
Creates and opens a new JMSRecordSender for sending the Avro Records.

Specified by:
start in interface org.robokind.api.messaging.MessageSender<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.DefaultMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>

stop

public void stop()
Closes the JMSRecordReceiver.

Specified by:
stop in interface org.robokind.api.messaging.MessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>
Overrides:
stop in class org.robokind.api.messaging.DefaultMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord,L extends org.robokind.api.common.utils.Listener<Msg>>


Copyright © 2011. All Rights Reserved.