ds.granules.scheduler

Class ExchangeProcessor

java.lang.Object

ds.granules.scheduler.ExchangeProcessor

public class ExchangeProcessor
extends Object

This is a class which is reponsible for processing various exchanges related to the deployment, discovery and advertisement of application instances and resources.

Author:

Shrideep Pallickara

Field Summary

Fields

Modifier and Type	Field and Description
static String	MODULE

Constructor Summary

Constructors

Constructor and Description
ExchangeProcessor(Diagnostics diagnostics, String deploymentStream, int numOfThreads)

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize()
void	onEvent(ds.funnel.topic.TopicDataEvent topicEvent)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE

public static final String MODULE

See Also:

Constant Field Values

Constructor Detail

ExchangeProcessor

public ExchangeProcessor(Diagnostics diagnostics,
                 String deploymentStream,
                 int numOfThreads)

Method Detail

initialize

public void initialize()
                throws CommunicationsException

Throws:

CommunicationsException

onEvent

public void onEvent(ds.funnel.topic.TopicDataEvent topicEvent)