/**
* OFPlugin provider implementation
*/
-public class OpenflowPluginProvider implements BindingAwareProvider {
+public class OpenflowPluginProvider implements BindingAwareProvider, AutoCloseable {
private BindingAwareBroker broker;
messageCountCommandProvider = new MessageCountCommandProvider(context, messageCountProvider);
messageCountCommandProvider.onSessionInitiated(session);
}
+
+ @Override
+ public void close() {
+ mdController.stop();
+ }
@Override
public void onSessionInitialized(ConsumerContext session) {