public abstract class MAppImpl
extends java.lang.Object
protected com.tibco.tibrv.TibrvQueueGroup m_tibQueueGroup
protected MApp m_app
protected MAppProperties m_appProperties
protected java.lang.String m_absConfigUrl
protected MAdvisory m_advisory
protected MAdvisoryListener m_advisoryListener
protected MRvSession m_processSession
protected MHawkRegistry m_hawkRegistry
protected MComponentRegistry m_componentRegistry
protected MClassRegistry m_classRegistry
protected MConfigDeserializer m_configDeserializer
protected MPropertiesRegistry m_propertiesRegistry
protected MProperties m_configProperties
protected MDispatcher m_dispatcher
protected MDispatcher m_defaultHawkDispatcher
protected RoundRobinQ m_queue
protected boolean m_isEventLoopStarted
protected MHostInfo m_hostInfo
protected MAdapterServiceInfo m_adapterServiceInfo
protected MTrace m_trace
protected MStartup m_controlBlock
protected int m_appState
protected int m_defaultMessageFormat
protected boolean m_xsdGenerationFlag
protected boolean m_isDispatchingRv
protected MRvSslConnectionSpec m_rvSslSpec
protected boolean m_dispatchRvFirst
protected int[] m_eventsReceivedHistory
protected int m_iIndexCount
protected static final int M_APP_CONSTRUCTED
protected static final int M_APP_PRE_INITIALIZE
protected static final int M_APP_INITIALIZED
protected static final int M_APP_STOP_REQUESTED
protected static final int M_APP_STOP_APPROVED
protected static final int M_APP_PRE_STOP
public static final int M_APP_STOPPED
protected static final int MAX_EVENTS_IN_HISTORY
protected static final int M_RV_EVENT_TYPE
protected static final int M_JMS_EVENT_TYPE
protected java.util.Vector m_customHawkMethods
protected boolean m_hasSubscriberAdvisorySent
public boolean nextEvent(long p_timelimit) throws MException
MException
public abstract void start(boolean p_startEventLoop) throws MException
MException
public void stop() throws MException
MException
public boolean createDefaultHawkMicroAgents(MHawkRegistry hawkRegistry) throws MException
MException
public void createConfigDeserializer()
public void onConfigDeserialize(MPropertiesRegistry p_propertiesRegistry) throws MException
MException
public void setupAdvisory()
public void setupPropertiesRegistry(com.tibco.infra.repository.RepoClient p_repoClient) throws MException
MException
public void setupClassRegistry(MPropertiesRegistry p_propertiesRegistry) throws MException
MException
public void setupDefaultTrace()
public MAppProperties getAppParameters()
public MTrace getTrace()
public MAdvisory getAdvisory()
public MAdvisoryListener getAdvisoryListener()
public void setAdvisoryListener(MAdvisoryListener p_listener) throws MException
MException
public MClassRegistry getClassRegistry()
public MHawkRegistry getHawkRegistry()
public MComponentRegistry getComponentRegistry()
public MComponent getComponentByName(java.lang.String p_name)
public MProperties getConfigProperties()
public MPropertiesRegistry getPropertiesRegistry()
public MPerformanceMonitor getPerfMon()
public MHostInfo getHostInfo()
public void setHostInfo(MHostInfo p_hostInfo)
public MAdapterServiceInfo getAdapterServiceInfo()
public void setAdapterServiceInfo(MAdapterServiceInfo p_adapterServiceInfo)
public MStartup getControlBlock()
public void setControlBlock(MStartup p_startup)
public MConfigDeserializer getConfigDeserializer()
public com.tibco.tibrv.TibrvQueueGroup getTibrvQueueGroup()
public void addSession(MSession session)
public void removeSession(MSession session)
public void setRvSslSpec(MRvSslConnectionSpec rvSslSpec)
public MRvSslConnectionSpec getRvSslSpec()
public MGUID newGUID()
protected void preOnTermination() throws MException
MException
protected void init()
protected void cleanup()
protected boolean initialize() throws MException
MException
protected void startEventLoop()
protected void stopEventLoop()
protected boolean shouldFavorRv()
public void addEventToHistory(int eventType)
protected boolean nextRvEvent(long lTimelimit) throws MException
MException
protected boolean nextJmsEvent(long plTimelimit) throws MException
MException
protected void printBanner()
protected void setupConfigUrl() throws MException
MException
protected void setupInstanceId()
protected void openTibrv()
protected void closeTibrv()
protected void onPluginInitialization() throws MException
MException
protected void onPluginTermination() throws MException
MException
public void addMethodToClassMicroAgent(MHawkMethod method) throws MException
MException
public java.lang.String[][] getGlobalVariables() throws MException
MException
public java.lang.String getGlobalVariable(java.lang.String name) throws MException
MException
public java.lang.String[][] getClientVariables()
public java.lang.String getClientVariable(java.lang.String name) throws MException
MException
public void setSubscriberAdvisorySent(boolean hasAdvisorySent)
public boolean hasSubscriberAdvisorySent()