public class ExchangeProcessor extends Object
Constructor and Description |
---|
ExchangeProcessor(Diagnostics diagnostics,
String deploymentStream,
int numOfThreads) |
public static final String MODULE
public ExchangeProcessor(Diagnostics diagnostics, String deploymentStream, int numOfThreads)
public void initialize() throws CommunicationsException
CommunicationsException
public void onEvent(ds.funnel.topic.TopicDataEvent topicEvent)
Copyright © 2015. All rights reserved.