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

Class PostgresTaskRepository

java.lang.Object

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

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

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

All Implemented Interfaces:

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

public class PostgresTaskRepository
extends JdbcTaskRepository.WithIntervalMultiplication

Nested Class Summary

Nested classes/interfaces inherited from class no.skatteetaten.fastsetting.formueinntekt.felles.task.jdbc.JdbcTaskRepository

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 inherited from class no.skatteetaten.fastsetting.formueinntekt.felles.task.jdbc.JdbcTaskRepository

CHANGE_LOG, concurrent, owner

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

INCEPTION

Constructor Summary

Constructors

Constructor	Description
PostgresTaskRepository(boolean concurrent, String owner)
PostgresTaskRepository(boolean concurrent, String owner, int bulkSize)

Method Summary

Modifier and Type	Method	Description
(package private) void	doFilter(Connection conn, String topic, Collection<String> identifiers, long sequence)
(package private) long	doPurge(Connection conn, String topic, long from, long to, TaskState lower, TaskState upper)
boolean	initialize(Connection conn, String topic)
Set<Task>	poll(Connection conn, String topic, int size)
void	purgeAll(Connection conn, String topic)
List<Task>	push(Connection conn, String topic, TaskSink.Insertion insertion, Collection<TaskCreation> creations)
void	refresh(Connection conn)

Methods inherited from class no.skatteetaten.fastsetting.formueinntekt.felles.task.jdbc.JdbcTaskRepository.WithIntervalMultiplication

expire

Methods inherited from class no.skatteetaten.fastsetting.formueinntekt.felles.task.jdbc.JdbcTaskRepository

complete, count, doComplete, doPoll, doRecreate, doReset, doTranscribe, getCountingHint, getOwner, getResultsHint, heartbeat, isConcurrent, owners, page, page, purge, purge, purgeOwners, reassign, recreate, recreate, register, resolve, results

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, 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

Constructor Details

PostgresTaskRepository

public PostgresTaskRepository(boolean concurrent,
 String owner)

PostgresTaskRepository

public PostgresTaskRepository(boolean concurrent,
 String owner,
 int bulkSize)

Method Details

initialize

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

Specified by:

initialize in interface TaskRepository<Connection,SQLException>

Overrides:

initialize in class JdbcTaskRepository

Throws:

SQLException

refresh

public void refresh(Connection conn)
             throws 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>

Overrides:

push in class JdbcTaskRepository

Throws:

SQLException

poll

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

Specified by:

poll in interface TaskSource<Connection,SQLException>

Overrides:

poll in class JdbcTaskRepository

Throws:

SQLException

doFilter

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

Overrides:

doFilter in class JdbcTaskRepository

Throws:

SQLException

purgeAll

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

Specified by:

purgeAll in interface TaskRepository<Connection,SQLException>

Overrides:

purgeAll in class JdbcTaskRepository

Throws:

SQLException

doPurge

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

Overrides:

doPurge in class JdbcTaskRepository

Throws:

SQLException