Package net.rubyeye.xmemcached.impl

Class MemcachedHandler

java.lang.Object

com.google.code.yanf4j.core.impl.HandlerAdapter

net.rubyeye.xmemcached.impl.MemcachedHandler

All Implemented Interfaces:

Handler

public class MemcachedHandler
extends HandlerAdapter

Memcached Session Handler,used for dispatching commands and session's lifecycle management

Author:

dennis

Field Summary

Fields

Modifier and Type	Field	Description
static IoBuffer	EMPTY_BUF

Constructor Summary

Constructors

Constructor	Description
MemcachedHandler(MemcachedClient client)

Method Summary

Modifier and Type	Method	Description
void	onExceptionCaught(Session session, Throwable throwable)
void	onMessageReceived(Session session, Object msg)	On receive message from memcached server
void	onMessageSent(Session session, Object msg)	put command which have been sent to queue
void	onSessionClosed(Session session)	Check if have to reconnect on session closed
void	onSessionIdle(Session session)	Do a heartbeat action
void	onSessionStarted(Session session)	On session started
protected void	reconnect(MemcachedTCPSession session)	Auto reconect to memcached server
void	setEnableHeartBeat(boolean enableHeartBeat)
void	start()
void	stop()

Methods inherited from class com.google.code.yanf4j.core.impl.HandlerAdapter

onSessionConnected, onSessionCreated, onSessionExpired

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_BUF

public static final IoBuffer EMPTY_BUF

Constructor Detail

MemcachedHandler

public MemcachedHandler(MemcachedClient client)

Method Detail

onMessageReceived

public final void onMessageReceived(Session session,
                                    Object msg)

On receive message from memcached server

Specified by:

onMessageReceived in interface Handler

Overrides:

onMessageReceived in class HandlerAdapter

setEnableHeartBeat

public void setEnableHeartBeat(boolean enableHeartBeat)

onMessageSent

public final void onMessageSent(Session session,
                                Object msg)

put command which have been sent to queue

Specified by:

onMessageSent in interface Handler

Overrides:

onMessageSent in class HandlerAdapter

onExceptionCaught

public void onExceptionCaught(Session session,
                              Throwable throwable)

Specified by:

onExceptionCaught in interface Handler

Overrides:

onExceptionCaught in class HandlerAdapter

onSessionStarted

public void onSessionStarted(Session session)

On session started

Specified by:

onSessionStarted in interface Handler

Overrides:

onSessionStarted in class HandlerAdapter

onSessionClosed

public final void onSessionClosed(Session session)

Check if have to reconnect on session closed

Specified by:

onSessionClosed in interface Handler

Overrides:

onSessionClosed in class HandlerAdapter

onSessionIdle

public void onSessionIdle(Session session)

Do a heartbeat action

Specified by:

onSessionIdle in interface Handler

Overrides:

onSessionIdle in class HandlerAdapter

reconnect

protected void reconnect(MemcachedTCPSession session)

Auto reconect to memcached server

Parameters:

session -

stop

public void stop()

start

public void start()