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
org.robokind.api.messaging.DefaultMessageSender<Msg,Rec,L>
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
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 |
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 sendingdestination
- JMS Destination to send torecordClass
- Class of the Avro Record to send
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.