Package org.jgroups.blocks

Class MemcachedConnector

java.lang.Object

org.jgroups.blocks.MemcachedConnector

All Implemented Interfaces:

Runnable

public class MemcachedConnector
extends Object
implements Runnable

Class which listens on a server socket for memcached clients, reads the requests, forwards them to an instance of PartitionedHashMap and sends the response. A memcached client should be able to work without changes once the memcached protocol (http://code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt) has been implemented completely.

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MemcachedConnector.Request

Constructor Summary

Constructors

Constructor	Description
MemcachedConnector(InetAddress bind_addr, int port, PartitionedHashMap<String,byte[]> cache)

Method Summary

Modifier and Type	Method	Description
InetAddress	getBindAddress()
PartitionedHashMap<String,byte[]>	getCache()
int	getPort()
Map<String,Object>	getStats()
Executor	getThreadPool()
int	getThreadPoolCoreThreads()
long	getThreadPoolIdleTime()
int	getThreadPoolMaxThreads()
void	run()
void	setBindAddress(InetAddress bind_addr)
void	setCache(PartitionedHashMap<String,byte[]> cache)
void	setPort(int port)
void	setThreadPool(Executor thread_pool)
void	setThreadPoolCoreThreads(int core_threads)
void	setThreadPoolIdleTime(long idle_time)
void	setThreadPoolMaxThreads(int max_threads)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

MemcachedConnector

public MemcachedConnector(InetAddress bind_addr,
 int port,
 PartitionedHashMap<String,byte[]> cache)

Method Details

getBindAddress

public InetAddress getBindAddress()

setBindAddress

public void setBindAddress(InetAddress bind_addr)

getPort

public int getPort()

setPort

public void setPort(int port)

getCache

public PartitionedHashMap<String,byte[]> getCache()

setCache

public void setCache(PartitionedHashMap<String,byte[]> cache)

getThreadPoolCoreThreads

public int getThreadPoolCoreThreads()

setThreadPoolCoreThreads

public void setThreadPoolCoreThreads(int core_threads)

getThreadPoolMaxThreads

public int getThreadPoolMaxThreads()

setThreadPoolMaxThreads

public void setThreadPoolMaxThreads(int max_threads)

getThreadPoolIdleTime

public long getThreadPoolIdleTime()

setThreadPoolIdleTime

public void setThreadPoolIdleTime(long idle_time)

getThreadPool

public Executor getThreadPool()

setThreadPool

public void setThreadPool(Executor thread_pool)

getStats

public Map<String,Object> getStats()

start

public void start()
           throws IOException,
MalformedObjectNameException,
MBeanRegistrationException

Throws:

IOException

MalformedObjectNameException

MBeanRegistrationException

stop

public void stop()
          throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable