public class SessionStore extends Object
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static TypeArg<SessionStore> |
__TYPE_ARG |
Constructor and Description |
---|
SessionStore(SessionStore delegate) |
Modifier and Type | Method and Description |
---|---|
void |
clear(Handler<AsyncResult<Boolean>> resultHandler)
Remove all sessions from the store
|
rx.Observable<Boolean> |
clearObservable()
Deprecated.
use
rxClear() instead |
void |
close()
Close the store
|
Session |
createSession(long timeout)
Create a new session using the default min length.
|
Session |
createSession(long timeout,
int length)
Create a new session
|
void |
delete(String id,
Handler<AsyncResult<Boolean>> resultHandler)
Delete the session with the specified ID
|
rx.Observable<Boolean> |
deleteObservable(String id)
Deprecated.
use
rxDelete(java.lang.String) instead |
void |
get(String id,
Handler<AsyncResult<Session>> resultHandler)
Get the session with the specified ID
|
SessionStore |
getDelegate() |
rx.Observable<Session> |
getObservable(String id)
Deprecated.
use
rxGet(java.lang.String) instead |
static SessionStore |
newInstance(SessionStore arg) |
void |
put(Session session,
Handler<AsyncResult<Boolean>> resultHandler)
Add a session with the specified ID
|
rx.Observable<Boolean> |
putObservable(Session session)
Deprecated.
use
rxPut(io.vertx.rxjava.ext.web.Session) instead |
long |
retryTimeout()
The retry timeout value in milli seconds used by the session handler when it retrieves a value from the store.
A non positive value means there is no retry at all.
|
rx.Single<Boolean> |
rxClear()
Remove all sessions from the store
|
rx.Single<Boolean> |
rxDelete(String id)
Delete the session with the specified ID
|
rx.Single<Session> |
rxGet(String id)
Get the session with the specified ID
|
rx.Single<Boolean> |
rxPut(Session session)
Add a session with the specified ID
|
rx.Single<Integer> |
rxSize()
Get the number of sessions in the store
|
void |
size(Handler<AsyncResult<Integer>> resultHandler)
Get the number of sessions in the store
|
rx.Observable<Integer> |
sizeObservable()
Deprecated.
use
rxSize() instead |
public static final TypeArg<SessionStore> __TYPE_ARG
public SessionStore(SessionStore delegate)
public SessionStore getDelegate()
public long retryTimeout()
public Session createSession(long timeout)
timeout
- - the session timeout, in mspublic Session createSession(long timeout, int length)
timeout
- - the session timeout, in mslength
- - the required length for the session idpublic void get(String id, Handler<AsyncResult<Session>> resultHandler)
id
- the unique ID of the sessionresultHandler
- will be called with a result holding the session, or a failure@Deprecated public rx.Observable<Session> getObservable(String id)
rxGet(java.lang.String)
insteadid
- the unique ID of the sessionpublic rx.Single<Session> rxGet(String id)
id
- the unique ID of the sessionpublic void delete(String id, Handler<AsyncResult<Boolean>> resultHandler)
id
- the unique ID of the sessionresultHandler
- will be called with a result true/false, or a failure@Deprecated public rx.Observable<Boolean> deleteObservable(String id)
rxDelete(java.lang.String)
insteadid
- the unique ID of the sessionpublic rx.Single<Boolean> rxDelete(String id)
id
- the unique ID of the sessionpublic void put(Session session, Handler<AsyncResult<Boolean>> resultHandler)
session
- the sessionresultHandler
- will be called with a result true/false, or a failure@Deprecated public rx.Observable<Boolean> putObservable(Session session)
rxPut(io.vertx.rxjava.ext.web.Session)
insteadsession
- the sessionpublic rx.Single<Boolean> rxPut(Session session)
session
- the sessionpublic void clear(Handler<AsyncResult<Boolean>> resultHandler)
resultHandler
- will be called with a result true/false, or a failure@Deprecated public rx.Observable<Boolean> clearObservable()
rxClear()
insteadpublic rx.Single<Boolean> rxClear()
public void size(Handler<AsyncResult<Integer>> resultHandler)
resultHandler
- will be called with the number, or a failure@Deprecated public rx.Observable<Integer> sizeObservable()
rxSize()
insteadpublic rx.Single<Integer> rxSize()
public void close()
public static SessionStore newInstance(SessionStore arg)
Copyright © 2017. All rights reserved.