com.atlassian.confluence.impl.messagequeue

Class AmqPayloadPersistenceServiceImpl

java.lang.Object

com.atlassian.confluence.impl.messagequeue.AmqPayloadPersistenceServiceImpl

All Implemented Interfaces:

AmqPayloadPersistenceService

public class AmqPayloadPersistenceServiceImpl
extends Object
implements AmqPayloadPersistenceService

Default implementation of AmqPayloadPersistenceService

Constructor Summary

Constructors

Constructor and Description
AmqPayloadPersistenceServiceImpl(com.atlassian.confluence.impl.messagequeue.AmqPayloadDao amqPayloadDao, org.springframework.transaction.PlatformTransactionManager transactionManager)

Method Summary

Modifier and Type	Method and Description
long	create(String payload) Stores the given payload and returns the key associated with the record
Optional<String>	findAmqPayload(long payloadId) Returns an Optional payload associated with provided payloadId
int	purge(Instant createdTimeThreshold) Purges the payload records which have been created before the threshold time specified

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqPayloadPersistenceServiceImpl

public AmqPayloadPersistenceServiceImpl(com.atlassian.confluence.impl.messagequeue.AmqPayloadDao amqPayloadDao,
                                        org.springframework.transaction.PlatformTransactionManager transactionManager)

Method Detail

create

public long create(String payload)

Description copied from interface: AmqPayloadPersistenceService

Stores the given payload and returns the key associated with the record

Specified by:

create in interface AmqPayloadPersistenceService

Parameters:

payload - non null payload to store

Returns:

key of the stored payload

findAmqPayload

public Optional<String> findAmqPayload(long payloadId)

Description copied from interface: AmqPayloadPersistenceService

Returns an Optional payload associated with provided payloadId

Specified by:

findAmqPayload in interface AmqPayloadPersistenceService

Parameters:

payloadId - key of the payload record

Returns:

Optional representing the payload if associated with this key. Else Empty optional

purge

public int purge(Instant createdTimeThreshold)

Description copied from interface: AmqPayloadPersistenceService

Purges the payload records which have been created before the threshold time specified

Specified by:

purge in interface AmqPayloadPersistenceService

Parameters:

createdTimeThreshold - threshold which filters the records to delete

Returns:

number of rows affected by the purge