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.core.sal;
10 import java.util.concurrent.TimeUnit;
12 import org.opendaylight.controller.sal.binding.api.NotificationProviderService;
13 import org.opendaylight.openflowplugin.openflow.md.core.session.IMessageDispatchService;
14 import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
16 import com.google.common.util.concurrent.ListeningExecutorService;
21 public class OFRpcTaskContext {
23 private IMessageDispatchService messageService;
24 private SessionContext session;
25 private NotificationProviderService rpcNotificationProviderService;
26 private long maxTimeout;
27 private TimeUnit maxTimeoutUnit;
28 private ListeningExecutorService rpcPool;
31 * @return the messageService
33 public IMessageDispatchService getMessageService() {
34 return messageService;
37 * @param messageService the messageService to set
39 public void setMessageService(IMessageDispatchService messageService) {
40 this.messageService = messageService;
45 public SessionContext getSession() {
49 * @param session the session to set
51 public void setSession(SessionContext session) {
52 this.session = session;
55 * @return the rpcNotificationProviderService
57 public NotificationProviderService getRpcNotificationProviderService() {
58 return rpcNotificationProviderService;
61 * @param rpcNotificationProviderService the rpcNotificationProviderService to set
63 public void setRpcNotificationProviderService(
64 NotificationProviderService rpcNotificationProviderService) {
65 this.rpcNotificationProviderService = rpcNotificationProviderService;
68 * @return the maxTimeout
70 public long getMaxTimeout() {
74 * @param maxTimeout the maxTimeout to set
76 public void setMaxTimeout(long maxTimeout) {
77 this.maxTimeout = maxTimeout;
80 * @return the maxTimeoutUnit
82 public TimeUnit getMaxTimeoutUnit() {
83 return maxTimeoutUnit;
86 * @param maxTimeoutUnit the maxTimeoutUnit to set
88 public void setMaxTimeoutUnit(TimeUnit maxTimeoutUnit) {
89 this.maxTimeoutUnit = maxTimeoutUnit;
94 public void setRpcPool(ListeningExecutorService rpcPool) {
95 this.rpcPool = rpcPool;
101 public ListeningExecutorService getRpcPool() {