psdi.iface.jms

Class KafkaErrorsCleanUp

java.lang.Object

psdi.iface.jms.KafkaErrorsCleanUp

public class KafkaErrorsCleanUp
extends java.lang.Object

An automic object that provides the lock object for the tenant operation.

Constructor Summary

Constructors

Constructor and Description
KafkaErrorsCleanUp() Default Constructor

Method Summary

Modifier and Type	Method and Description
void	clearMessageReprocessing(UserInfo userInfo) Deelete all message re-processing records which beyond retention time

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaErrorsCleanUp

public KafkaErrorsCleanUp()

Default Constructor

Method Detail

clearMessageReprocessing

public void clearMessageReprocessing(UserInfo userInfo)
                              throws MXException,
                                     java.rmi.RemoteException

Deelete all message re-processing records which beyond retention time

Parameters:

tenantid - tenant Id

Throws:

java.rmi.RemoteException

MXException