org.apache.reef.io.network.naming

Class NameRegistryClient

java.lang.Object

org.apache.reef.io.network.naming.NameRegistryClient

All Implemented Interfaces:

AutoCloseable, NamingRegistry, Stage

public class NameRegistryClient
extends Object
implements Stage, NamingRegistry

Naming registry client

Constructor Summary

Constructors

Constructor and Description
NameRegistryClient(String serverAddr, int serverPort, IdentifierFactory factory) Constructs a naming registry client
NameRegistryClient(String serverAddr, int serverPort, long timeout, IdentifierFactory factory) Constructs a naming registry client
NameRegistryClient(String serverAddr, int serverPort, long timeout, IdentifierFactory factory, BlockingQueue<NamingRegisterResponse> replyQueue, Transport transport)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes resources
void	register(Identifier id, InetSocketAddress addr) Registers an (identifier, address) mapping
void	unregister(Identifier id) Unregisters an identifier

Methods inherited from class java.lang.Object

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

Constructor Detail

NameRegistryClient

public NameRegistryClient(String serverAddr,
                  int serverPort,
                  IdentifierFactory factory)

Constructs a naming registry client

Parameters:

serverAddr - a name server address

serverPort - a name server port

factory - an identifier factory

NameRegistryClient

public NameRegistryClient(String serverAddr,
                  int serverPort,
                  long timeout,
                  IdentifierFactory factory)

Constructs a naming registry client

Parameters:

serverAddr - a name server address

serverPort - a name server port

timeout - timeout in ms

factory - an identifier factory

NameRegistryClient

public NameRegistryClient(String serverAddr,
                  int serverPort,
                  long timeout,
                  IdentifierFactory factory,
                  BlockingQueue<NamingRegisterResponse> replyQueue,
                  Transport transport)

Method Detail

register

public void register(Identifier id,
            InetSocketAddress addr)
              throws Exception

Registers an (identifier, address) mapping

Specified by:

register in interface NamingRegistry

Parameters:

id - an identifier

addr - an Internet socket address

Throws:

Exception

unregister

public void unregister(Identifier id)
                throws IOException

Unregisters an identifier

Specified by:

unregister in interface NamingRegistry

Parameters:

id - an identifier

Throws:

IOException

close

public void close()
           throws Exception

Closes resources

Specified by:

close in interface AutoCloseable

Throws:

Exception