org.robokind.impl.messaging.lifecycle
Class JMSAvroMessageSenderLifecycle<Msg,Rec extends org.apache.avro.generic.IndexedRecord>
java.lang.Object
org.robokind.api.common.property.PropertyChangeNotifier
org.robokind.api.common.lifecycle.AbstractLifecycleProvider<org.robokind.api.messaging.MessageSender,JMSAvroMessageSender<Msg,Rec>>
org.robokind.impl.messaging.lifecycle.JMSAvroMessageSenderLifecycle<Msg,Rec>
- All Implemented Interfaces:
- org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageSender>, org.robokind.api.common.property.PropertyChangeSource
public class JMSAvroMessageSenderLifecycle<Msg,Rec extends org.apache.avro.generic.IndexedRecord>
- extends org.robokind.api.common.lifecycle.AbstractLifecycleProvider<org.robokind.api.messaging.MessageSender,JMSAvroMessageSender<Msg,Rec>>
- Author:
- Matthew Stevenson
Nested classes/interfaces inherited from interface org.robokind.api.common.lifecycle.ServiceLifecycleProvider |
org.robokind.api.common.lifecycle.ServiceLifecycleProvider.Validator |
Fields inherited from class org.robokind.api.common.lifecycle.AbstractLifecycleProvider |
myRegistrationProperties, myService, myServiceClassNames |
Fields inherited from interface org.robokind.api.common.lifecycle.ServiceLifecycleProvider |
PROP_DEPENDENCY_ADDED, PROP_DEPENDENCY_REMOVED |
Constructor Summary |
JMSAvroMessageSenderLifecycle(org.jflux.api.core.Adapter<Msg,Rec> adapter,
Class<Msg> messageClass,
Class<Rec> recordClass,
String senderId,
String sessionId,
String destinationId)
|
JMSAvroMessageSenderLifecycle(org.jflux.api.core.Adapter<Msg,Rec> adapter,
Class<Msg> messageClass,
Class<Rec> recordClass,
String senderId,
String sessionId,
String destinationId,
String contentType)
|
Methods inherited from class org.robokind.api.common.lifecycle.AbstractLifecycleProvider |
addRuntimeDependency, dependencyChanged, getDependencyDescriptors, getRegistrationProperties, getService, getServiceClassNames, isSatisfied, removeRuntimeDependency, start |
Methods inherited from class org.robokind.api.common.property.PropertyChangeNotifier |
addPropertyChangeListener, addPropertyChangeListener, clearAllListeners, clearListeners, fireIndexedPropertyChange, fireIndexedPropertyChange, fireIndexedPropertyChange, firePropertyChange, firePropertyChange, firePropertyChange, firePropertyChange, getPropertyChangeListeners, getPropertyChangeListeners, hasListeners, removePropertyChangeListener, removePropertyChangeListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.robokind.api.common.property.PropertyChangeSource |
addPropertyChangeListener, addPropertyChangeListener, removePropertyChangeListener, removePropertyChangeListener |
theSession
protected static final String theSession
- See Also:
- Constant Field Values
theDestination
protected static final String theDestination
- See Also:
- Constant Field Values
JMSAvroMessageSenderLifecycle
public JMSAvroMessageSenderLifecycle(org.jflux.api.core.Adapter<Msg,Rec> adapter,
Class<Msg> messageClass,
Class<Rec> recordClass,
String senderId,
String sessionId,
String destinationId,
String contentType)
JMSAvroMessageSenderLifecycle
public JMSAvroMessageSenderLifecycle(org.jflux.api.core.Adapter<Msg,Rec> adapter,
Class<Msg> messageClass,
Class<Rec> recordClass,
String senderId,
String sessionId,
String destinationId)
create
protected JMSAvroMessageSender<Msg,Rec> create(Map<String,Object> dependencies)
- Specified by:
create
in class org.robokind.api.common.lifecycle.AbstractLifecycleProvider<org.robokind.api.messaging.MessageSender,JMSAvroMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord>>
stop
public void stop()
- Specified by:
stop
in interface org.robokind.api.common.lifecycle.ServiceLifecycleProvider<org.robokind.api.messaging.MessageSender>
- Overrides:
stop
in class org.robokind.api.common.lifecycle.AbstractLifecycleProvider<org.robokind.api.messaging.MessageSender,JMSAvroMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord>>
handleChange
protected void handleChange(String dependencyId,
Object service,
Map<String,Object> dependencies)
- Specified by:
handleChange
in class org.robokind.api.common.lifecycle.AbstractLifecycleProvider<org.robokind.api.messaging.MessageSender,JMSAvroMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord>>
getServiceClass
public Class<org.robokind.api.messaging.MessageSender> getServiceClass()
- Specified by:
getServiceClass
in class org.robokind.api.common.lifecycle.AbstractLifecycleProvider<org.robokind.api.messaging.MessageSender,JMSAvroMessageSender<Msg,Rec extends org.apache.avro.generic.IndexedRecord>>
Copyright © 2011-2013. All Rights Reserved.