Package org.jboss.modcluster.advertise.impl

Class AdvertiseListenerImpl

java.lang.Object

org.jboss.modcluster.advertise.impl.AdvertiseListenerImpl

All Implemented Interfaces:

AutoCloseable, AdvertiseListener

public class AdvertiseListenerImpl
extends Object
implements AdvertiseListener

Listens for advertise messages sent by mod_cluster reverse proxy.

Author:

Mladen Turk, Radoslav Husar

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_ENCODING
static String	RFC_822_FMT

Constructor Summary

Constructors

Constructor	Description
AdvertiseListenerImpl(MCMPHandler commHandler, AdvertiseConfiguration config, DatagramChannelFactory channelFactory)	Constructors a new AdvertiseListenerImpl

Method Summary

Modifier and Type	Method	Description
static void	clearBuffer(Buffer buffer)	JDK-compatible clear operating on Buffer instead of ByteBuffer.
void	close()	Stops the advertise listener.
static void	flipBuffer(Buffer buffer)	JDK-compatible flip operating on Buffer instead of ByteBuffer.
AdvertisedServer	getServer(String name)	Get AdvertiseServer server.
boolean	isListening()	Returns true if listener is accepting the advertise messages; false if the listener was stopped or is experiencing network problems.

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,
                             DatagramChannelFactory channelFactory)
                      throws IOException

Constructors a new AdvertiseListenerImpl

Parameters:

commHandler - event handler that will be used for status and new server notifications

config - advertise configuration

channelFactory - a multicast channel factory

Throws:

IOException

Method Detail

getServer

public AdvertisedServer getServer(String name)

Get AdvertiseServer server.

Parameters:

name - Server name to get.

close

public void close()
           throws IOException

Stops the advertise listener.

Specified by:

close in interface AdvertiseListener

Specified by:

close in interface AutoCloseable

Throws:

IOException - If an I/O error occurs while closing the underlying channel.

See Also:

MulticastChannel.close()

isListening

public boolean isListening()

Description copied from interface: AdvertiseListener

Returns true if listener is accepting the advertise messages; false if the listener was stopped or is experiencing network problems.

Specified by:

isListening in interface AdvertiseListener

flipBuffer

public static void flipBuffer(Buffer buffer)

JDK-compatible flip operating on Buffer instead of ByteBuffer. See MODCLUSTER-743.

Parameters:

buffer - a buffer to flip

clearBuffer

public static void clearBuffer(Buffer buffer)

JDK-compatible clear operating on Buffer instead of ByteBuffer. See MODCLUSTER-743.

Parameters:

buffer - a buffer to clear