diff --git a/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModule.java b/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModule.java index f69e091d4..84564035e 100644 --- a/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModule.java +++ b/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModule.java @@ -27,6 +27,7 @@ import org.marketcetera.module.DataEmitterSupport; import org.marketcetera.module.DataFlowID; import org.marketcetera.module.DataRequest; +import org.marketcetera.module.DisplayName; import org.marketcetera.module.IllegalRequestParameterValue; import org.marketcetera.module.Module; import org.marketcetera.module.ModuleException; @@ -99,6 +100,15 @@ public final String getFeedStatus() } return feedStatus.toString(); } + /* (non-Javadoc) + * @see org.marketcetera.marketdata.AbstractMarketDataModuleMXBean#disconnect() + */ + @Override + @DisplayName("Causes the feed to disconnect") + public void disconnect() + { + feed.logout(); + } /* (non-Javadoc) * @see org.marketcetera.marketdata.AbstractMarketDataModuleMXBean#reconnect() */ diff --git a/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModuleMXBean.java b/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModuleMXBean.java index dd7ae2e12..b432f204c 100644 --- a/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModuleMXBean.java +++ b/core/src/main/java/org/marketcetera/marketdata/AbstractMarketDataModuleMXBean.java @@ -40,6 +40,11 @@ public interface AbstractMarketDataModuleMXBean */ @DisplayName("Causes the feed to resubmit existing queries") public void reconnect(); + /** + * Disconnect from the feed. + */ + @DisplayName("Causes the feed to disconnect") + public void disconnect(); /** * Gets the set of capabilities for this market data feed. *