com.airepublic.microverse.core.discovery

Class MulticastRegistryDiscoverer

java.lang.Object

com.airepublic.microverse.core.discovery.MulticastRegistryDiscoverer

All Implemented Interfaces:

IRegistryDiscoverer, com.airepublic.multicast.IMulticastMessageHandler, Closeable, AutoCloseable

@Singleton
public class MulticastRegistryDiscoverer
extends Object
implements IRegistryDiscoverer, com.airepublic.multicast.IMulticastMessageHandler, Closeable

Discovers service-registries by making a multicast request.

Author:

Torsten Oltmanns

Field Summary

Fields

Modifier and Type	Field and Description
static String	ANNOUNCE_REGISTRY_ALL
static String	REQUEST_REGISTRY_ALL

Method Summary

Modifier and Type	Method and Description
void	close()
static MulticastRegistryDiscoverer	create(RegistryCache registryCache) Creates a new instance by defining the RegistryCache. NOTE: This is for standalone use when not in a CDI context.
void	handle(InetAddress fromHost, int fromPort, byte[] data)
void	requestRegistries() Locates all registries and puts them in the mutually used RegistryCache.
protected void	send(String type, byte[] message) Sends the message of the specified type to the multicast socket.

Methods inherited from class java.lang.Object

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

Field Detail

REQUEST_REGISTRY_ALL

public static final String REQUEST_REGISTRY_ALL

See Also:

Constant Field Values

ANNOUNCE_REGISTRY_ALL

public static final String ANNOUNCE_REGISTRY_ALL

See Also:

Constant Field Values

Method Detail

create

public static MulticastRegistryDiscoverer create(RegistryCache registryCache)

Creates a new instance by defining the RegistryCache.
NOTE: This is for standalone use when not in a CDI context.

Parameters:

registryCache -

Returns:

requestRegistries

public void requestRegistries()

Description copied from interface: IRegistryDiscoverer

Locates all registries and puts them in the mutually used RegistryCache.

Specified by:

requestRegistries in interface IRegistryDiscoverer

handle

public void handle(InetAddress fromHost,
                   int fromPort,
                   byte[] data)

Specified by:

handle in interface com.airepublic.multicast.IMulticastMessageHandler

send

protected void send(String type,
                    byte[] message)
             throws ServiceException

Sends the message of the specified type to the multicast socket.

Parameters:

type - the type of message

message - the message data

Throws:

ServiceException

close

@PreDestroy
public void close()

Specified by:

close in interface IRegistryDiscoverer

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable