public class SessionExpirationScheduler extends Object implements Scheduler
Constructor and Description |
---|
SessionExpirationScheduler(Batcher<TransactionBatch> batcher,
Remover<String> remover) |
SessionExpirationScheduler(Batcher<TransactionBatch> batcher,
Remover<String> remover,
ScheduledExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
void |
cancel(Locality locality)
Cancels any previous scheduled tasks for session which are no longer local to the current node
|
void |
cancel(String sessionId)
Cancels a previously scheduled task for the specified session
|
void |
close()
Closes any resources used by this scheduler.
|
void |
schedule(String sessionId,
ImmutableSessionMetaData metaData)
Schedules a task for the specified session.
|
public SessionExpirationScheduler(Batcher<TransactionBatch> batcher, Remover<String> remover)
public SessionExpirationScheduler(Batcher<TransactionBatch> batcher, Remover<String> remover, ScheduledExecutorService executor)
public void cancel(String sessionId)
Scheduler
public void schedule(String sessionId, ImmutableSessionMetaData metaData)
Scheduler
public void cancel(Locality locality)
Scheduler
public void close()
Scheduler
close
in interface AutoCloseable
close
in interface Scheduler
Copyright © 2018 JBoss by Red Hat. All rights reserved.