org.openhubframework.openhub.core.common.asynch.queue

Class PartlyFailedMessagesJob

java.lang.Object

org.openhubframework.openhub.core.common.asynch.queue.PartlyFailedMessagesJob

@Profile(value="prod")
 @Component
public class PartlyFailedMessagesJob
extends Object

Route definition that starts job process that pools message queue (=database) and takes MsgStateEnum.PARTLY_FAILED messages for further processing.

Repeat interval for this job is load from configuration . Job running concurrent in all nodes in cluster at the same time.

Author:

Petr Juza

See Also:

JobStarterForMessagePooling.start(), CoreProps.ASYNCH_PARTLY_FAILED_REPEAT_TIME_SEC

Constructor Summary

Constructors

Constructor and Description
PartlyFailedMessagesJob()

Method Summary

Modifier and Type	Method and Description
void	invokeJob() Invoke job for process MsgStateEnum.PARTLY_FAILED messages

Methods inherited from class java.lang.Object

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

Constructor Detail

PartlyFailedMessagesJob

public PartlyFailedMessagesJob()

Method Detail

invokeJob

public final void invokeJob()
                     throws Exception

Invoke job for process MsgStateEnum.PARTLY_FAILED messages

Throws:

Exception