Package org.zalando.nakadiproducer.eventlog.impl

Class EventLogRepositoryImpl

java.lang.Object

org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

All Implemented Interfaces:

org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

public class EventLogRepositoryImpl
extends Object
implements org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

Constructor Summary

Constructors

Constructor	Description
EventLogRepositoryImpl(org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate)

Method Summary

Modifier and Type	Method	Description
void	delete(org.zalando.nakadiproducer.eventlog.impl.EventLog eventLog)
void	deleteAll()
Collection<org.zalando.nakadiproducer.eventlog.impl.EventLog>	findByLockedByAndLockedUntilGreaterThan(String lockedBy, java.time.Instant lockedUntil)
org.zalando.nakadiproducer.eventlog.impl.EventLog	findOne(Integer id)
void	lockSomeMessages(String lockId, java.time.Instant now, java.time.Instant lockExpires)
void	persist(Collection<org.zalando.nakadiproducer.eventlog.impl.EventLog> eventLogs)
void	persist(org.zalando.nakadiproducer.eventlog.impl.EventLog eventLog)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventLogRepositoryImpl

public EventLogRepositoryImpl(org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate)

Method Detail

findByLockedByAndLockedUntilGreaterThan

public Collection<org.zalando.nakadiproducer.eventlog.impl.EventLog> findByLockedByAndLockedUntilGreaterThan(String lockedBy,
                                                                                                             java.time.Instant lockedUntil)

Specified by:

findByLockedByAndLockedUntilGreaterThan in interface org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

lockSomeMessages

public void lockSomeMessages(String lockId,
                             java.time.Instant now,
                             java.time.Instant lockExpires)

Specified by:

lockSomeMessages in interface org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

delete

public void delete(org.zalando.nakadiproducer.eventlog.impl.EventLog eventLog)

Specified by:

delete in interface org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

persist

public void persist(org.zalando.nakadiproducer.eventlog.impl.EventLog eventLog)

Specified by:

persist in interface org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

persist

public void persist(Collection<org.zalando.nakadiproducer.eventlog.impl.EventLog> eventLogs)

Specified by:

persist in interface org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.zalando.nakadiproducer.eventlog.impl.EventLogRepository

findOne

public org.zalando.nakadiproducer.eventlog.impl.EventLog findOne(Integer id)

Specified by:

findOne in interface org.zalando.nakadiproducer.eventlog.impl.EventLogRepository