2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.openflowplugin.openflow.md.queue;
11 import org.opendaylight.openflowplugin.api.openflow.md.queue.MessageSourcePollRegistrator;
14 * closable registration for {@link org.opendaylight.openflowplugin.api.openflow.md.queue.MessageSourcePollRegistrator}
15 * @param <IN> queue input message type
17 public class MessageSourcePollRegistration<IN> implements AutoCloseable {
19 private MessageSourcePollRegistrator<IN> messageSourceRegistry;
20 private IN messageSource;
23 * @param messageSourceRegistry
24 * @param messageSource
26 public MessageSourcePollRegistration(MessageSourcePollRegistrator<IN> messageSourceRegistry,
28 this.messageSourceRegistry = messageSourceRegistry;
29 this.messageSource = messageSource;
33 public void close() throws Exception {
34 messageSourceRegistry.unregisterMessageSource(messageSource);