org.robokind.impl.messaging.lifecycle
Class JMSAvroMessageSenderLifecycle<Msg,Rec extends org.apache.avro.generic.IndexedRecord>

java.lang.Object
  extended by org.robokind.api.common.property.PropertyChangeNotifier
      extended by org.robokind.api.common.lifecycle.AbstractLifecycleProvider<org.robokind.api.messaging.MessageSender,JMSAvroMessageSender<Msg,Rec>>
          extended by 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 Class Summary
 
Nested classes/interfaces inherited from interface org.robokind.api.common.lifecycle.ServiceLifecycleProvider
org.robokind.api.common.lifecycle.ServiceLifecycleProvider.Validator
 
Field Summary
protected static String theDestination
           
protected static String theSession
           
 
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)
           
 
Method Summary
protected  JMSAvroMessageSender<Msg,Rec> create(Map<String,Object> dependencies)
           
 Class<org.robokind.api.messaging.MessageSender> getServiceClass()
           
protected  void handleChange(String dependencyId, Object service, Map<String,Object> dependencies)
           
 void stop()
           
 
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
 

Field Detail

theSession

protected static final String theSession
See Also:
Constant Field Values

theDestination

protected static final String theDestination
See Also:
Constant Field Values
Constructor Detail

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)
Method Detail

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.