package Ġcom . netflix . spin n aker . ke el . sql Ċ Ċ import Ġcom . fasterxml . jackson . databind . js ont ype . Named Type Ċ import Ġcom . netflix . spin n aker . ke el . scm . Commit Created Event Ċ import Ġcom . netflix . spin n aker . ke el . jackson . register Ke el Api Module Ċ import Ġcom . netflix . spin n aker . ke el . persistence . Work Queue Repository Tests Ċ import Ġcom . netflix . spin n aker . ke el . serialization . configured ObjectMapper Ċ import Ġcom . netflix . spin n aker . k ork . sql . config . Retry Properties Ċ import Ġcom . netflix . spin n aker . k ork . sql . config . Sql Retry Properties Ċ Ċ internal Ġclass ĠSql Work Queue Repository Tests : ĠWork Queue Repository Tests < Sql Work Queue Repository >() Ġ{ ĊĠ Ġprivate Ġval Ġj oo q Ġ= Ġtest Database . context ĊĠ Ġprivate Ġval Ġretry Properties Ġ= ĠRetry Properties ( 1 , Ġ 0 ) ĊĠ Ġprivate Ġval Ġsql Retry Ġ= ĠSql Retry ( Sql Retry Properties ( retry Properties , Ġretry Properties )) ĊĊĠ Ġprivate Ġval Ġmapper Ġ= Ġconfigured ObjectMapper () ĊĠĠĠ Ġ. register Ke el Api Module () ĊĠĠĠ Ġ. apply Ġ{ ĊĠĠĠĠĠ Ġregister Sub types ( Named Type ( Commit Created Event :: class . java , Ġ" commit . created ")) ĊĠĠĠ Ġ} ĊĊĊĊĠ Ġoverride Ġfun Ġcreate Subject (): ĠSql Work Queue Repository Ġ= ĊĠĠĠ ĠSql Work Queue Repository ( ĊĠĠĠĠĠ Ġj oo q Ġ= Ġj oo q , ĊĠĠĠĠĠ Ġclock Ġ= Ġclock , ĊĠĠĠĠĠ Ġmapper Ġ= Ġmapper , ĊĠĠĠĠĠ Ġsql Retry Ġ= Ġsql Retry , ĊĠĠĠ Ġ) Ċ } Ċ