com.solarmetric.rd.kodo.runtime.datacache.plugins
Class UDPCache

java.lang.Object
  |
  +--com.solarmetric.rd.kodo.runtime.datacache.plugins.LocalCache
        |
        +--com.solarmetric.rd.kodo.runtime.datacache.plugins.DistributedCache
              |
              +--com.solarmetric.rd.kodo.runtime.datacache.plugins.SocketDistributedCache
                    |
                    +--com.solarmetric.rd.kodo.runtime.datacache.plugins.UDPCache

All Implemented Interfaces:

Configurable, DataCache

public class UDPCache

extends SocketDistributedCache

A distributed cache implementation that uses UDP for broadcasting change notifications.

Nested Class Summary

Nested classes inherited from class com.solarmetric.rd.kodo.runtime.datacache.plugins.SocketDistributedCache

SocketDistributedCache.HostAddress, SocketDistributedCache.SocketCacheListener

Field Summary

Fields inherited from class com.solarmetric.rd.kodo.runtime.datacache.plugins.LocalCache

cache

Constructor Summary

UDPCache()

Method Summary

void	endConfiguration() Subclasses that need to perform actions in Configurable#endConfiguration must invoke this method.
protected SocketDistributedCache.SocketCacheListener	newSocketCacheListener() Creates a new SocketCacheListener configured to listen on the appropriate port/protocol for a given SocketDistributedCache implementation.
protected void	sendUpdatePacket(byte[] bytes) Sends a change notification packet to other machines in this cache cluster.
void	setAddresses(java.lang.String names)
void	setMulticastGroup(java.lang.String name)
void	setPacketLength(int val)
void	setUseMulticast(boolean val)

Methods inherited from class com.solarmetric.rd.kodo.runtime.datacache.plugins.SocketDistributedCache

broadcastUpdate, getID, getLocalhost, getPort, setPort, startConfiguration

Methods inherited from class com.solarmetric.rd.kodo.runtime.datacache.plugins.DistributedCache

batchUpdate, log, log, receivedBatchUpdate

Methods inherited from class com.solarmetric.rd.kodo.runtime.datacache.plugins.LocalCache

clear, close, get, getCacheMap, getCacheSize, newCacheMap, pin, put, remove, removeAll, setCacheSize, unpin

Methods inherited from class java.lang.Object

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

Constructor Detail

UDPCache

public UDPCache()
         throws java.net.UnknownHostException

Method Detail

setPacketLength

public void setPacketLength(int val)

setUseMulticast

public void setUseMulticast(boolean val)

setMulticastGroup

public void setMulticastGroup(java.lang.String name)
                       throws java.net.UnknownHostException

java.net.UnknownHostException

setAddresses

public void setAddresses(java.lang.String names)
                  throws java.net.UnknownHostException

java.net.UnknownHostException

endConfiguration

public void endConfiguration()

Description copied from class: SocketDistributedCache

Subclasses that need to perform actions in Configurable#endConfiguration must invoke this method.

Specified by:

endConfiguration in interface Configurable

Overrides:

endConfiguration in class SocketDistributedCache

sendUpdatePacket

protected void sendUpdatePacket(byte[] bytes)
                         throws java.io.IOException

Description copied from class: SocketDistributedCache

Sends a change notification packet to other machines in this cache cluster.

Specified by:

sendUpdatePacket in class SocketDistributedCache

java.io.IOException

newSocketCacheListener

protected SocketDistributedCache.SocketCacheListener newSocketCacheListener()
                                                                     throws java.io.IOException,
                                                                            java.net.SocketException

Description copied from class: SocketDistributedCache

Creates a new SocketCacheListener configured to listen on the appropriate port/protocol for a given SocketDistributedCache implementation.

Specified by:

newSocketCacheListener in class SocketDistributedCache

java.io.IOException

java.net.SocketException