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

Class OracleTaskRepository

java.lang.Object

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

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

All Implemented Interfaces:

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

public class OracleTaskRepository
extends JdbcTaskRepository

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

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
OracleTaskRepository(boolean concurrent, String owner)
OracleTaskRepository(boolean concurrent, String owner, int lockSize, int bulkSize, boolean hint)

Method Summary

Modifier and Type	Method	Description
(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)
void	expire(Connection conn, long timeout, TimeUnit unit)
(package private) String	getCountingHint(boolean identified)
void	heartbeat(Connection conn)
boolean	initialize(Connection conn, String topic)
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

complete, count, doComplete, doRecreate, doReset, doTranscribe, getOwner, isConcurrent, page, page, poll, purge, purge, reassign, recreate, recreate, register, resolve

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, page, page, purge, purge, reassign, recreate, resolve, 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 Detail

OracleTaskRepository

public OracleTaskRepository(boolean concurrent,
                            String owner)

OracleTaskRepository

public OracleTaskRepository(boolean concurrent,
                            String owner,
                            int lockSize,
                            int bulkSize,
                            boolean hint)

Method Detail

heartbeat

public void heartbeat(Connection conn)
               throws SQLException

Specified by:

heartbeat in interface TaskRepository<Connection,SQLException>

Overrides:

heartbeat in class JdbcTaskRepository

Throws:

SQLException

expire

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

Specified by:

expire in interface TaskRepository<Connection,SQLException>

Overrides:

expire in class JdbcTaskRepository

Throws:

SQLException

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

doFilter

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

Overrides:

doFilter in class JdbcTaskRepository

Throws:

SQLException

doPoll

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

Overrides:

doPoll 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

getCountingHint

String getCountingHint(boolean identified)

Overrides:

getCountingHint in class JdbcTaskRepository