import org.opendaylight.openflowjava.protocol.api.connection.ConnectionConfiguration;
import org.opendaylight.openflowjava.protocol.spi.connection.SwitchConnectionProvider;
import org.opendaylight.openflowplugin.openflow.md.OFConstants;
+import org.opendaylight.openflowplugin.openflow.md.core.extension.ExtensionConverterProvider;
import org.opendaylight.openflowplugin.openflow.md.core.session.OFSessionUtil;
import org.opendaylight.openflowplugin.openflow.md.core.translator.ErrorTranslator;
import org.opendaylight.openflowplugin.openflow.md.core.translator.ErrorV10Translator;
private ErrorHandlerSimpleImpl errorHandler;
+ private ExtensionConverterProvider extensionConverterProvider;
+
/**
* @return translator mapping
*/
int rpcThreadLimit = 10;
ListeningExecutorService rpcPoolDelegator = createRpcPoolSpyDecorated(rpcThreadLimit, messageSpyCounter);
OFSessionUtil.getSessionManager().setRpcPool(rpcPoolDelegator);
+ OFSessionUtil.getSessionManager().setExtensionConverterProvider(extensionConverterProvider);
}
OFSessionUtil.releaseSessionManager();
errorHandler = null;
}
+
+ /**
+ * @param extensionConverterProvider
+ */
+ public void setExtensionConverterProvider(ExtensionConverterProvider extensionConverterProvider) {
+ this.extensionConverterProvider = extensionConverterProvider;
+ }
}