org.apache.reef.wake.remote.impl

Class Subscription<T>

java.lang.Object

org.apache.reef.wake.remote.impl.Subscription<T>

Type Parameters:

T - type

All Implemented Interfaces:

AutoCloseable

public class Subscription<T>
extends Object
implements AutoCloseable

Subscription of a handler.

Constructor Summary

Constructors

Constructor and Description
Subscription(T token, org.apache.reef.wake.remote.impl.HandlerContainer<T> handlerContainer) Constructs a subscription.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Unsubscribes this subscription.
T	getToken() Gets the token of this subscription.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Subscription

public Subscription(T token,
            org.apache.reef.wake.remote.impl.HandlerContainer<T> handlerContainer)

Constructs a subscription.

Parameters:

token - the token for finding the subscription

handlerContainer - the container managing handlers

Method Detail

getToken

public T getToken()

Gets the token of this subscription.

Returns:

the token of this subscription

close

public void close()
           throws Exception

Unsubscribes this subscription.

Specified by:

close in interface AutoCloseable

Throws:

Exception