Modifier and Type	Class and Description
private class	MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread A multicast receiver which continously receives heartbeats.

Modifier and Type	Field and Description
private final InetAddress	groupMulticastAddress
private final Integer	groupMulticastPort
private InetAddress	hostAddress
private static final Logger	LOG
private final MulticastRMICacheManagerPeerProvider	peerProvider
private ExecutorService	processingThreadPool
private MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread	receiverThread
private Set<E>	rmiUrlsProcessingQueue
private MulticastSocket	socket
private volatile boolean	stopped

Access	Constructor and Description
public	MulticastKeepaliveHeartbeatReceiver(MulticastRMICacheManagerPeerProvider peerProvider, InetAddress multicastAddress, Integer multicastPort, InetAddress hostAddress) Constructor.

Modifier and Type	Method and Description
public final void	dispose() Shutdown the heartbeat.
pack-priv final void	init() Start.

groupMulticastAddress	back to summary
private final InetAddress groupMulticastAddress

groupMulticastPort	back to summary
private final Integer groupMulticastPort

hostAddress	back to summary
private InetAddress hostAddress

LOG	back to summary
private static final Logger LOG

peerProvider	back to summary
private final MulticastRMICacheManagerPeerProvider peerProvider

processingThreadPool	back to summary
private ExecutorService processingThreadPool

receiverThread	back to summary
private MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread receiverThread

rmiUrlsProcessingQueue	back to summary
private Set<E> rmiUrlsProcessingQueue

socket	back to summary
private MulticastSocket socket

stopped	back to summary
private volatile boolean stopped

MulticastKeepaliveHeartbeatReceiver	back to summary
public MulticastKeepaliveHeartbeatReceiver(MulticastRMICacheManagerPeerProvider peerProvider, InetAddress multicastAddress, Integer multicastPort, InetAddress hostAddress) Constructor.

dispose	back to summary
public final void dispose() Shutdown the heartbeat.

init	back to summary
pack-priv final void init() throws IOException Start.

net.sf.ehcache.distribution back to summary

private final Class MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread

Class Inheritance

extends Thread

java.lang.Object
java.lang.Thread
net.sf.ehcache.distribution.MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread

A multicast receiver which continously receives heartbeats.

Field Summary

Inherited from java.lang.Thread:: MAX_PRIORITY MIN_PRIORITY NORM_PRIORITY

Constructor Summary

Access	Constructor and Description
public	MulticastReceiverThread() Constructor

Method Summary

Modifier and Type	Method and Description
public final void	interrupt() Overrides java.lang.Thread.interrupt. Interrupts this thread.
private void	processPayload(byte[] compressedPayload)
private void	processRmiUrls(final String rmiUrls) This method forks a new executor to process the received heartbeat in a thread pool.
private void	registerNotification(String rmiUrl)
public final void	run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. This method is run by the thread when it executes.
private boolean	Returns: true if our own hostname and listener port are found in the list. This then means we have caught our onw multicast, and should be ignored. self(String rmiUrls)

Constructor Detail

MulticastReceiverThread	back to summary
public MulticastReceiverThread() Constructor

Method Detail

interrupt back to summary

interrupt	back to summary
public final void interrupt() Overrides java.lang.Thread.interrupt. Doc from java.lang.Thread.interrupt. Interrupts this thread. Unless the current thread is interrupting itself, which is always permitted, the `checkAccess` method of this thread is invoked, which may cause a `SecurityException` to be thrown. If this thread is blocked in an invocation of the `wait()`, `wait(long)`, or `wait(long, int)` methods of the `Object` class, or of the `join()`, `join(long)`, `join(long, int)`, `sleep(long)`, or `sleep(long, int)` methods of this class, then its interrupt status will be cleared and it will receive an `InterruptedException`. If this thread is blocked in an I/O operation upon an `InterruptibleChannel` then the channel will be closed, the thread's interrupt status will be set, and the thread will receive a `java.nio.channels.ClosedByInterruptException`. If this thread is blocked in a `java.nio.channels.Selector` then the thread's interrupt status will be set and it will return immediately from the selection operation, possibly with a non-zero value, just as if the selector's `wakeup` method were invoked. If none of the previous conditions hold then this thread's interrupt status will be set. Interrupting a thread that is not alive need not have any effect. Annotations @Override

public final void interrupt()

Overrides java.lang.Thread.interrupt.

Doc from java.lang.Thread.interrupt.

Interrupts this thread.

Unless the current thread is interrupting itself, which is always permitted, the checkAccess method of this thread is invoked, which may cause a SecurityException to be thrown.

If this thread is blocked in an invocation of the wait(), wait(long), or wait(long, int) methods of the Object class, or of the join(), join(long), join(long, int), sleep(long), or sleep(long, int) methods of this class, then its interrupt status will be cleared and it will receive an InterruptedException.

If this thread is blocked in an I/O operation upon an InterruptibleChannel then the channel will be closed, the thread's interrupt status will be set, and the thread will receive a java.nio.channels.ClosedByInterruptException.

If this thread is blocked in a java.nio.channels.Selector then the thread's interrupt status will be set and it will return immediately from the selection operation, possibly with a non-zero value, just as if the selector's wakeup method were invoked.

If none of the previous conditions hold then this thread's interrupt status will be set.

Interrupting a thread that is not alive need not have any effect.

Annotations

@Override

processPayload	back to summary
private void processPayload(byte[] compressedPayload)

processRmiUrls	back to summary
private void processRmiUrls(final String rmiUrls) This method forks a new executor to process the received heartbeat in a thread pool. That way each remote cache manager cannot interfere with others. In the worst case, we have as many concurrent threads as remote cache managers.

processRmiUrls

back to summary

private void processRmiUrls(final String rmiUrls)

This method forks a new executor to process the received heartbeat in a thread pool. That way each remote cache manager cannot interfere with others.

In the worst case, we have as many concurrent threads as remote cache managers.

registerNotification	back to summary
private void registerNotification(String rmiUrl)

run back to summary

run	back to summary
public final void run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. Doc from java.lang.Thread.run. This method is run by the thread when it executes. Subclasses of `Thread` may override this method. This method is not intended to be invoked directly. If this thread is a platform thread created with a `Runnable` task then invoking this method will invoke the task's `run` method. If this thread is a virtual thread then invoking this method directly does nothing. Annotations @Override

public final void run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

Doc from java.lang.Thread.run.

This method is run by the thread when it executes. Subclasses of Thread may override this method.

This method is not intended to be invoked directly. If this thread is a platform thread created with a Runnable task then invoking this method will invoke the task's run method. If this thread is a virtual thread then invoking this method directly does nothing.

Annotations

@Override

self	back to summary
private boolean self(String rmiUrls) Returns:boolean true if our own hostname and listener port are found in the list. This then means we have caught our onw multicast, and should be ignored.

public final Class MulticastKeepaliveHeartbeatReceiver

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail