Package org.eclipse.jetty.memcached.session

Class MemcachedSessionDataMap

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.memcached.session.MemcachedSessionDataMap

All Implemented Interfaces:

SessionDataMap, LifeCycle

@ManagedObject
public class MemcachedSessionDataMap
extends AbstractLifeCycle
implements SessionDataMap

MemcachedSessionDataMap Uses memcached as a cache for SessionData.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MemcachedSessionDataMap.SessionDataTranscoder	SessionDataTranscoder We override memcached deserialization to use our classloader-aware ObjectInputStream.

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
protected net.rubyeye.xmemcached.XMemcachedClientBuilder	_builder
protected net.rubyeye.xmemcached.MemcachedClient	_client
protected SessionContext	_context
protected int	_expirySec
protected boolean	_heartbeats
static final String	DEFAULT_HOST
static final String	DEFAULT_PORT

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor	Description
MemcachedSessionDataMap(String host, String port)
MemcachedSessionDataMap(List<InetSocketAddress> addresses)
MemcachedSessionDataMap(List<InetSocketAddress> addresses, int[] weights)

Method Summary

Modifier and Type	Method	Description
boolean	delete(String id)	Delete session data
protected void	doStop()	Method to override to stop the lifecycle
net.rubyeye.xmemcached.XMemcachedClientBuilder	getBuilder()
int	getExpirySec()	Expiry time for memached entries.
void	initialize(SessionContext context)	Initialize this data map for the given context.
boolean	isHeartbeats()
SessionData	load(String id)	Read in session data.
void	setExpirySec(int sec)
void	setHeartbeats(boolean heartbeats)
void	store(String id, SessionData data)	Store the session data.

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addEventListener, doStart, getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeEventListener, setEventListeners, start, stop, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.component.LifeCycle

addEventListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeEventListener, start, stop

Field Details

DEFAULT_HOST

public static final String DEFAULT_HOST

See Also:

• Constant Field Values

DEFAULT_PORT

public static final String DEFAULT_PORT

See Also:

• Constant Field Values

_client

protected net.rubyeye.xmemcached.MemcachedClient _client

_expirySec

protected int _expirySec

_heartbeats

protected boolean _heartbeats

_builder

protected net.rubyeye.xmemcached.XMemcachedClientBuilder _builder

_context

protected SessionContext _context

Constructor Details

MemcachedSessionDataMap

public MemcachedSessionDataMap(String host,
 String port)

Parameters:

host - address of memcache server

port - address of memcache server

MemcachedSessionDataMap

public MemcachedSessionDataMap(List<InetSocketAddress> addresses)

MemcachedSessionDataMap

public MemcachedSessionDataMap(List<InetSocketAddress> addresses,
 int[] weights)

Method Details

getBuilder

public net.rubyeye.xmemcached.XMemcachedClientBuilder getBuilder()

Returns:

the builder

setExpirySec

public void setExpirySec(int sec)

Parameters:

sec - the expiry to use in seconds

getExpirySec

@ManagedAttribute(value="memcached expiry time in sec",
                  readonly=true)
public int getExpirySec()

Expiry time for memached entries.

Returns:

memcached expiry time in sec

isHeartbeats

@ManagedAttribute(value="enable memcached heartbeats",
                  readonly=true)
public boolean isHeartbeats()

setHeartbeats

public void setHeartbeats(boolean heartbeats)

initialize

public void initialize(SessionContext context)

Description copied from interface: SessionDataMap

Initialize this data map for the given context. A SessionDataMap can only be used by one context(/session manager).

Specified by:

initialize in interface SessionDataMap

Parameters:

context - context associated

load

public SessionData load(String id)
                 throws Exception

Description copied from interface: SessionDataMap

Read in session data.

Specified by:

load in interface SessionDataMap

Parameters:

id - identity of session to load

Returns:

the SessionData matching the id

Throws:

Exception - if unable to load session data

store

public void store(String id,
 SessionData data)
           throws Exception

Description copied from interface: SessionDataMap

Store the session data.

Specified by:

store in interface SessionDataMap

Parameters:

id - identity of session to store

data - info of session to store

Throws:

Exception - if unable to write session data

delete

public boolean delete(String id)
               throws Exception

Description copied from interface: SessionDataMap

Delete session data

Specified by:

delete in interface SessionDataMap

Parameters:

id - identity of session to delete

Returns:

true if the session was deleted

Throws:

Exception - if unable to delete session data

doStop

protected void doStop()
               throws Exception

Description copied from class: AbstractLifeCycle

Method to override to stop the lifecycle

Overrides:

doStop in class AbstractLifeCycle

Throws:

Exception - If there was a problem stopping. Will cause a transition to FAILED state