Package no.skatteetaten.fastsetting.formueinntekt.felles.task.jdbc

Class JdbcTaskRepository

java.lang.Object

no.skatteetaten.fastsetting.formueinntekt.felles.task.jdbc.JdbcTaskRepository

All Implemented Interfaces:

TaskRepository<Connection,SQLException>, TaskReviver<Connection,SQLException>, TaskSink<Connection,SQLException>, TaskSource<Connection,SQLException>

Direct Known Subclasses:

JdbcTaskRepository.WithIntervalMultiplication, OracleTaskRepository

public class JdbcTaskRepository
extends Object
implements TaskRepository<Connection,SQLException>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	JdbcTaskRepository.WithIntervalMultiplication

Nested classes/interfaces inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskRepository

TaskRepository.Counting, TaskRepository.Direction, TaskRepository.Listing, TaskRepository.Snapshot, TaskRepository.Summary

Nested classes/interfaces inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskReviver

TaskReviver.Revived, TaskReviver.Revivification

Nested classes/interfaces inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskSink

TaskSink.Insertion

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHANGE_LOG
protected final boolean	concurrent
protected final String	owner

Fields inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskRepository

INCEPTION

Constructor Summary

Constructors

Constructor	Description
JdbcTaskRepository(boolean concurrent, String owner)

Method Summary

Modifier and Type	Method	Description
void	complete(Connection conn, String topic, Map<Task,TaskDecision> decisions)
Map<String,Map<TaskState,TaskRepository.Summary>>	count(Connection conn, TaskRepository.Snapshot snapshot, TaskRepository.Counting counting, long from, long to)
(package private) void	doComplete(Connection conn, String topic, Map<Task,TaskDecision> decisions)
(package private) void	doFilter(Connection conn, String topic, Collection<String> identifiers, long sequence)
(package private) Set<Task>	doPoll(Connection conn, String topic, TaskState state, long from, long to, int size)
(package private) long	doPurge(Connection conn, String topic, long from, long to, TaskState lower, TaskState upper)
(package private) <TASK extends Task> Map<TASK,Task>	doRecreate(Connection conn, String topic, TaskSink.Insertion insertion, Collection<TASK> tasks, TaskState lower, TaskState upper)
(package private) <TASK extends Task> Map<TASK,Task>	doReset(Connection conn, String topic, Collection<TASK> tasks, TaskState lower, TaskState upper)
(package private) void	doTranscribe(Connection conn, String topic, Collection<? extends Task> tasks, Function<Task,TaskState> resolver, TaskState lower, TaskState upper)
void	expire(Connection conn, long timeout, TimeUnit unit)
(package private) String	getCountingHint(boolean identified)
String	getOwner()
(package private) String	getResultsHint()
void	heartbeat(Connection conn)
boolean	initialize(Connection conn, String topic)
boolean	isConcurrent()
Set<String>	owners(Connection conn, long timeout, TimeUnit unit)
List<TaskInfo>	page(Connection conn, String topic, long sequence, int size, TaskRepository.Direction direction)
List<TaskInfo>	page(Connection conn, String topic, TaskRepository.Listing listing, long sequence, int size, TaskRepository.Direction direction)
Set<Task>	poll(Connection conn, String topic, int size)
long	purge(Connection conn, String topic, long from, long to)
long	purge(Connection conn, String topic, TaskState state, long from, long to)
void	purgeAll(Connection conn, String topic)
int	purgeOwners(Connection conn, long timeout, TimeUnit unit)
List<Task>	push(Connection conn, String topic, TaskSink.Insertion insertion, Collection<TaskCreation> creations)
void	reassign(Connection conn, String topic, Map<Task,TaskResult> tasks)
<TASK extends Task> Map<TASK,Task>	recreate(Connection conn, String topic, TaskReviver.Revivification revivification, Set<TASK> tasks)
Map<Task,Task>	recreate(Connection conn, String topic, TaskReviver.Revivification revivification, TaskReviver.Revived revived, long from, long to, int size)
boolean	register(Connection conn)
long	resolve(Connection conn, OffsetDateTime dateTime, boolean preceding)
Map<String,Map<TaskResult,Long>>	results(Connection conn, OffsetDateTime from, OffsetDateTime to)

Methods inherited from class java.lang.Object

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

Methods inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskRepository

count, count, count, count, count, page, page, page, page, page, page, purge, purge, reassign, recreate, refresh, resolve, resolve, results, task, task

Methods inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskReviver

recreate, recreate

Methods inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskSink

push, push, push, push

Methods inherited from interface no.skatteetaten.fastsetting.formueinntekt.felles.task.api.TaskSource

complete, poll

Field Details

CHANGE_LOG

public static final String CHANGE_LOG

See Also:

• Constant Field Values

concurrent

protected final boolean concurrent

owner

protected final String owner

Constructor Details

JdbcTaskRepository

public JdbcTaskRepository(boolean concurrent,
 String owner)

Method Details

isConcurrent

public boolean isConcurrent()

getOwner

public String getOwner()

register

public boolean register(Connection conn)
                 throws SQLException

Specified by:

register in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

owners

public Set<String> owners(Connection conn,
 long timeout,
 TimeUnit unit)
                   throws SQLException

Specified by:

owners in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

heartbeat

public void heartbeat(Connection conn)
               throws SQLException

Specified by:

heartbeat in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

expire

public void expire(Connection conn,
 long timeout,
 TimeUnit unit)
            throws SQLException

Specified by:

expire in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

initialize

public boolean initialize(Connection conn,
 String topic)
                   throws SQLException

Specified by:

initialize in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

push

public List<Task> push(Connection conn,
 String topic,
 TaskSink.Insertion insertion,
 Collection<TaskCreation> creations)
                throws SQLException

Specified by:

push in interface TaskSink<Connection,SQLException>

Throws:

SQLException

doFilter

void doFilter(Connection conn,
 String topic,
 Collection<String> identifiers,
 long sequence)
       throws SQLException

Throws:

SQLException

poll

public Set<Task> poll(Connection conn,
 String topic,
 int size)
               throws SQLException

Specified by:

poll in interface TaskSource<Connection,SQLException>

Throws:

SQLException

doPoll

Set<Task> doPoll(Connection conn,
 String topic,
 TaskState state,
 long from,
 long to,
 int size)
          throws SQLException

Throws:

SQLException

doTranscribe

void doTranscribe(Connection conn,
 String topic,
 Collection<? extends Task> tasks,
 Function<Task,TaskState> resolver,
 TaskState lower,
 TaskState upper)
           throws SQLException

Throws:

SQLException

doComplete

void doComplete(Connection conn,
 String topic,
 Map<Task,TaskDecision> decisions)
         throws SQLException

Throws:

SQLException

doRecreate

<TASK extends Task> Map<TASK,Task> doRecreate(Connection conn,
 String topic,
 TaskSink.Insertion insertion,
 Collection<TASK> tasks,
 TaskState lower,
 TaskState upper)
                                       throws SQLException

Throws:

SQLException

doReset

<TASK extends Task> Map<TASK,Task> doReset(Connection conn,
 String topic,
 Collection<TASK> tasks,
 TaskState lower,
 TaskState upper)
                                    throws SQLException

Throws:

SQLException

complete

public void complete(Connection conn,
 String topic,
 Map<Task,TaskDecision> decisions)
              throws SQLException

Specified by:

complete in interface TaskSource<Connection,SQLException>

Throws:

SQLException

reassign

public void reassign(Connection conn,
 String topic,
 Map<Task,TaskResult> tasks)
              throws SQLException

Specified by:

reassign in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

recreate

public Map<Task,Task> recreate(Connection conn,
 String topic,
 TaskReviver.Revivification revivification,
 TaskReviver.Revived revived,
 long from,
 long to,
 int size)
                        throws SQLException

Specified by:

recreate in interface TaskReviver<Connection,SQLException>

Throws:

SQLException

recreate

public <TASK extends Task> Map<TASK,Task> recreate(Connection conn,
 String topic,
 TaskReviver.Revivification revivification,
 Set<TASK> tasks)
                                            throws SQLException

Specified by:

recreate in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

page

public List<TaskInfo> page(Connection conn,
 String topic,
 long sequence,
 int size,
 TaskRepository.Direction direction)
                    throws SQLException

Specified by:

page in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

page

public List<TaskInfo> page(Connection conn,
 String topic,
 TaskRepository.Listing listing,
 long sequence,
 int size,
 TaskRepository.Direction direction)
                    throws SQLException

Specified by:

page in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

count

public Map<String,Map<TaskState,TaskRepository.Summary>> count(Connection conn,
 TaskRepository.Snapshot snapshot,
 TaskRepository.Counting counting,
 long from,
 long to)
                                                        throws SQLException

Specified by:

count in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

getCountingHint

String getCountingHint(boolean identified)

results

public Map<String,Map<TaskResult,Long>> results(Connection conn,
 OffsetDateTime from,
 OffsetDateTime to)
                                         throws SQLException

Specified by:

results in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

getResultsHint

String getResultsHint()

purgeAll

public void purgeAll(Connection conn,
 String topic)
              throws SQLException

Specified by:

purgeAll in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

purgeOwners

public int purgeOwners(Connection conn,
 long timeout,
 TimeUnit unit)
                throws SQLException

Specified by:

purgeOwners in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

purge

public long purge(Connection conn,
 String topic,
 long from,
 long to)
           throws SQLException

Specified by:

purge in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

purge

public long purge(Connection conn,
 String topic,
 TaskState state,
 long from,
 long to)
           throws SQLException

Specified by:

purge in interface TaskRepository<Connection,SQLException>

Throws:

SQLException

doPurge

long doPurge(Connection conn,
 String topic,
 long from,
 long to,
 TaskState lower,
 TaskState upper)
      throws SQLException

Throws:

SQLException

resolve

public long resolve(Connection conn,
 OffsetDateTime dateTime,
 boolean preceding)
             throws SQLException

Specified by:

resolve in interface TaskRepository<Connection,SQLException>

Throws:

SQLException