org.jboss.modcluster.advertise.impl

Class AdvertiseListenerImpl

java.lang.Object

org.jboss.modcluster.advertise.impl.AdvertiseListenerImpl

All Implemented Interfaces:

AdvertiseListener

public class AdvertiseListenerImpl
extends Object
implements AdvertiseListener

Listens for Advertise messages from mod_cluster

Author:

Mladen Turk

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_ENCODING
static String	RFC_822_FMT

Constructor Summary

Constructors

Constructor and Description
AdvertiseListenerImpl(MCMPHandler commHandler, AdvertiseConfiguration config, MulticastSocketFactory socketFactory) Constructors a new AdvertiseListenerImpl

Method Summary

Modifier and Type	Method and Description
void	destroy() Deallocate listener and close sockets.
AdvertisedServer	getServer(String name) Get AdvertiseServer server.
Collection<AdvertisedServer>	getServers() Get Collection of all AdvertisedServer instances.
void	interruptDatagramReader()
boolean	isListening() True if listener is accepting the advetise messages. If false it means that listener is experiencing some network problems if running.
void	pause() Pause the listener, which will make it stop accepting new advertise messages.
void	removeServer(AdvertisedServer server) Remove the AdvertisedServer from the collection.
void	resume() Resume the listener, which will make it start accepting new advertise messages again.
void	start() Start the Listener, creating listener thread.
void	stop() Stop the endpoint.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ENCODING

public static final String DEFAULT_ENCODING

See Also:

Constant Field Values

RFC_822_FMT

public static final String RFC_822_FMT

See Also:

Constant Field Values

Constructor Detail

AdvertiseListenerImpl

public AdvertiseListenerImpl(MCMPHandler commHandler,
                             AdvertiseConfiguration config,
                             MulticastSocketFactory socketFactory)
                      throws IOException

Constructors a new AdvertiseListenerImpl

Parameters:

eventHandler - The event handler that will be used for status and new server notifications.

config - our configuration

socketFactory - a multicast socket factory

Throws:

IOException

Method Detail

getServers

public Collection<AdvertisedServer> getServers()

Get Collection of all AdvertisedServer instances.

getServer

public AdvertisedServer getServer(String name)

Get AdvertiseServer server.

Parameters:

name - Server name to get.

removeServer

public void removeServer(AdvertisedServer server)

Remove the AdvertisedServer from the collection.

Parameters:

server - Server to remove.

start

public void start()
           throws IOException

Description copied from interface: AdvertiseListener

Start the Listener, creating listener thread.

Specified by:

start in interface AdvertiseListener

Throws:

IOException

See Also:

AdvertiseListener.start()

pause

public void pause()

Description copied from interface: AdvertiseListener

Pause the listener, which will make it stop accepting new advertise messages.

Specified by:

pause in interface AdvertiseListener

See Also:

AdvertiseListener.pause()

resume

public void resume()

Description copied from interface: AdvertiseListener

Resume the listener, which will make it start accepting new advertise messages again.

Specified by:

resume in interface AdvertiseListener

See Also:

AdvertiseListener.resume()

interruptDatagramReader

public void interruptDatagramReader()

stop

public void stop()

Description copied from interface: AdvertiseListener

Stop the endpoint. This will cause all processing threads to stop.

Specified by:

stop in interface AdvertiseListener

See Also:

AdvertiseListener.stop()

destroy

public void destroy()

Description copied from interface: AdvertiseListener

Deallocate listener and close sockets.

Specified by:

destroy in interface AdvertiseListener

See Also:

AdvertiseListener.destroy()

isListening

public boolean isListening()

True if listener is accepting the advetise messages.
If false it means that listener is experiencing some network problems if running.