AbstractServiceConnectionManager (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.jobmaster.slotpool.AbstractServiceConnectionManager<S>

All Implemented Interfaces:

ServiceConnectionManager<S>
```
public class AbstractServiceConnectionManager<S>
extends Object
implements ServiceConnectionManager<S>
```
Base class for service connection managers, taking care of the connection handling.

Field Summary

Fields
Modifier and Type Field Description

protected Object lock

protected S service

Constructor Summary

Constructors
Constructor Description

AbstractServiceConnectionManager()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`checkNotClosed()`
`void`	`close()`	Close the service connection manager.
`void`	`connect(S service)`	Connect to the given service.
`void`	`disconnect()`	Disconnect from the current service.
`protected boolean`	`isConnected()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - lock
```
protected final Object lock
```
  - service
```
@Nullable
protected S service
```
- Constructor Detail
  - AbstractServiceConnectionManager
```
public AbstractServiceConnectionManager()
```
- Method Detail
  - connect
```
public final void connect(S service)
```
    Description copied from interface: ServiceConnectionManager
    
    Connect to the given service.
    
    Specified by:
    
    connect in interface ServiceConnectionManager<S>
    
    Parameters:
    
    service - service to connect to
  - disconnect
```
public final void disconnect()
```
    Description copied from interface: ServiceConnectionManager
    
    Disconnect from the current service.
    
    Specified by:
    
    disconnect in interface ServiceConnectionManager<S>
  - close
```
public final void close()
```
    Description copied from interface: ServiceConnectionManager
    
    Close the service connection manager. A closed manager must not be used again.
    
    Specified by:
    
    close in interface ServiceConnectionManager<S>
  - checkNotClosed
```
protected final void checkNotClosed()
```
  - isConnected
```
protected final boolean isConnected()
```