com.atlassian.confluence.messagequeue

Interface AmqPayloadPersistenceService

All Known Implementing Classes:

AmqPayloadPersistenceServiceImpl

public interface AmqPayloadPersistenceService

Responsible for providing basic Create, Find and Purge operations for Amq Payload. The criterion which decides whether an Amq message should be stored rests with the caller

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

Method Detail

create

long create(String payload)

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

Parameters:

payload - non null payload to store

Returns:

key of the stored payload

Throws:

NullPointerException - if payload is null

findAmqPayload

Optional<String> findAmqPayload(long payloadId)

Returns an Optional payload associated with provided payloadId

Parameters:

payloadId - key of the payload record

Returns:

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

Throws:

NullPointerException - if payloadId is null

purge

int purge(Instant createdTimeThreshold)

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

Parameters:

createdTimeThreshold - threshold which filters the records to delete

Returns:

number of rows affected by the purge

Throws:

NullPointerException - if createdTimeThreshold is null