public class MemcachedHandler extends HandlerAdapter
Constructor and Description |
---|
MemcachedHandler(MemcachedClient client) |
Modifier and Type | Method and 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() |
onSessionConnected, onSessionCreated, onSessionExpired
public static final IoBuffer EMPTY_BUF
public MemcachedHandler(MemcachedClient client)
public final void onMessageReceived(Session session, Object msg)
onMessageReceived
in interface Handler
onMessageReceived
in class HandlerAdapter
public void setEnableHeartBeat(boolean enableHeartBeat)
public final void onMessageSent(Session session, Object msg)
onMessageSent
in interface Handler
onMessageSent
in class HandlerAdapter
public void onExceptionCaught(Session session, Throwable throwable)
onExceptionCaught
in interface Handler
onExceptionCaught
in class HandlerAdapter
public void onSessionStarted(Session session)
onSessionStarted
in interface Handler
onSessionStarted
in class HandlerAdapter
public final void onSessionClosed(Session session)
onSessionClosed
in interface Handler
onSessionClosed
in class HandlerAdapter
public void onSessionIdle(Session session)
onSessionIdle
in interface Handler
onSessionIdle
in class HandlerAdapter
protected void reconnect(MemcachedTCPSession session)
session
- public void stop()
public void start()
Copyright © 2021. All rights reserved.