org.openhubframework.openhub.core.common.dao

Class MessageDaoJpaImpl

java.lang.Object

org.openhubframework.openhub.core.common.dao.MessageDaoJpaImpl

All Implemented Interfaces:

MessageDao

@Repository
public class MessageDaoJpaImpl
extends Object
implements MessageDao

JPA implementation of MessageDao interface.

Author:

Petr Juza

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_MESSAGES_IN_ONE_QUERY

Constructor Summary

Constructors

Constructor and Description
MessageDaoJpaImpl()

Method Summary

Modifier and Type	Method and Description
Message	findByCorrelationId(String correlationId, ExternalSystemExtEnum sourceSystem) Finds message by source system and correlation ID.
List<Message>	findChildMessages(Message msg) Finds all child messages of specified parent message.
List<Message>	findChildMessagesForParent(Message parentMessage) Finds all child message for parent message.
Message	findEagerMessage(Long msgId) Finds message by its ID with eager loading.
Message	findMessage(Long msgId) Finds message by its ID.
List<Message>	findMessagesByFilter(MessageFilter filter, long limit) Finds messages by multiple fields, hold together in MessageFilter.
protected String	findMessagesByFilterFulltextSql(String placeholder) Fulltext SQL used with fulltext field of messageFilter in operation findMessagesByFilter.
Message	findPartlyFailedMessage(Duration interval) Finds ONE message in state MsgStateEnum.PARTLY_FAILED.
Message	findPostponedMessage(Duration interval) Finds ONE message in state MsgStateEnum.POSTPONED.
List<Message>	findProcessingMessages(Duration interval) Finds processing messages to repair process.
int	getCountMessages(MsgStateEnum state, Duration interval) Gets count of messages in specified state
int	getCountProcessingMessagesForFunnel(String funnelValue, Duration idleInterval, String funnelCompId) Gets count of processing messages (PROCESSING, WAITING, WAITING_FOR_RES) with same funnel value and for specified funnel ID.
Message	getMessage(Long msgId) Gets message by its ID.
List<Message>	getMessagesForGuaranteedOrderForFunnel(String funnelValue, Duration idleInterval, boolean excludeFailedState, String funnelCompId) Gets list of messages with specified funnel value for guaranteed processing order of messages for specified funnel.
List<Message>	getMessagesForGuaranteedOrderForRoute(String funnelValue, boolean excludeFailedState) Gets list of messages with specified funnel value for guaranteed processing order of whole routes.
void	insert(Message msg) Inserts new message.
void	update(Message msg) Updates message.
boolean	updateMessageInQueueUnderLock(Message msg, Node processingNode) Updates Message into state MsgStateEnum.IN_QUEUE (set start timestamp in queue) - gets lock for message.
boolean	updateMessageProcessingUnderLock(Message msg, Node processingNode) Updates Message into state MsgStateEnum.PROCESSING (set start timestamp of processing) - gets lock for message.

Methods inherited from class java.lang.Object

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

Field Detail

MAX_MESSAGES_IN_ONE_QUERY

public static final int MAX_MESSAGES_IN_ONE_QUERY

See Also:

Constant Field Values

Constructor Detail

MessageDaoJpaImpl

public MessageDaoJpaImpl()

Method Detail

insert

@Transactional(propagation=MANDATORY)
public void insert(Message msg)

Description copied from interface: MessageDao

Inserts new message.

Specified by:

insert in interface MessageDao

Parameters:

msg - the message

update

@Transactional(propagation=MANDATORY)
public void update(Message msg)

Description copied from interface: MessageDao

Updates message.

Specified by:

update in interface MessageDao

Parameters:

msg - the message

findMessage

@Nullable
public Message findMessage(Long msgId)

Description copied from interface: MessageDao

Finds message by its ID.

Specified by:

findMessage in interface MessageDao

Parameters:

msgId - the message ID

Returns:

message or null if not available

findEagerMessage

@Nullable
public Message findEagerMessage(Long msgId)

Description copied from interface: MessageDao

Finds message by its ID with eager loading.

Specified by:

findEagerMessage in interface MessageDao

Parameters:

msgId - the message ID

Returns:

message or null if not available

getMessage

public Message getMessage(Long msgId)

Description copied from interface: MessageDao

Gets message by its ID.

Specified by:

getMessage in interface MessageDao

Parameters:

msgId - the message ID

Returns:

message

findChildMessages

public List<Message> findChildMessages(Message msg)

Description copied from interface: MessageDao

Finds all child messages of specified parent message.

Specified by:

findChildMessages in interface MessageDao

Parameters:

msg - the message

Returns:

list of child messages

findChildMessagesForParent

public List<Message> findChildMessagesForParent(Message parentMessage)

Description copied from interface: MessageDao

Finds all child message for parent message.

Specified by:

findChildMessagesForParent in interface MessageDao

Parameters:

parentMessage - parent message

Returns:

list of child messages

findByCorrelationId

@Nullable
public Message findByCorrelationId(String correlationId,
                                             @Nullable
                                             ExternalSystemExtEnum sourceSystem)

Description copied from interface: MessageDao

Finds message by source system and correlation ID.

Specified by:

findByCorrelationId in interface MessageDao

Parameters:

correlationId - correlation ID

sourceSystem - the source system

Returns:

message or null if not available

findPartlyFailedMessage

@Nullable
public Message findPartlyFailedMessage(Duration interval)

Description copied from interface: MessageDao

Finds ONE message in state MsgStateEnum.PARTLY_FAILED.

Specified by:

findPartlyFailedMessage in interface MessageDao

Parameters:

interval - Interval (in seconds) between two tries of partly failed messages.

Returns:

message or null if there is no any message

findPostponedMessage

@Nullable
public Message findPostponedMessage(Duration interval)

Description copied from interface: MessageDao

Finds ONE message in state MsgStateEnum.POSTPONED.

Specified by:

findPostponedMessage in interface MessageDao

Parameters:

interval - Interval (in seconds) after that can be postponed message processed again

Returns:

message or null if there is no any message

updateMessageProcessingUnderLock

public boolean updateMessageProcessingUnderLock(Message msg,
                                                Node processingNode)

Description copied from interface: MessageDao

Updates Message into state MsgStateEnum.PROCESSING (set start timestamp of processing) - gets lock for message.

Specified by:

updateMessageProcessingUnderLock in interface MessageDao

Parameters:

msg - the message

processingNode - node that process message from parameter

Returns:

true when update was successful otherwise false

updateMessageInQueueUnderLock

public boolean updateMessageInQueueUnderLock(Message msg,
                                             Node processingNode)

Description copied from interface: MessageDao

Updates Message into state MsgStateEnum.IN_QUEUE (set start timestamp in queue) - gets lock for message.

Specified by:

updateMessageInQueueUnderLock in interface MessageDao

Parameters:

msg - the message

processingNode - node that process message from parameter

Returns:

true when update was successful otherwise false

findProcessingMessages

public List<Message> findProcessingMessages(Duration interval)

Description copied from interface: MessageDao

Finds processing messages to repair process.

Specified by:

findProcessingMessages in interface MessageDao

Parameters:

interval - Interval (in seconds) after that processing messages are probably in dead-lock

Returns:

list of messages

getCountMessages

public int getCountMessages(MsgStateEnum state,
                            @Nullable
                            Duration interval)

Description copied from interface: MessageDao

Gets count of messages in specified state

Specified by:

getCountMessages in interface MessageDao

Parameters:

state - the state

interval - Interval (in seconds) after that messages must be updates; in other words get count of messages updated in specified interval

Returns:

count

getCountProcessingMessagesForFunnel

public int getCountProcessingMessagesForFunnel(String funnelValue,
                                               Duration idleInterval,
                                               String funnelCompId)

Description copied from interface: MessageDao

Gets count of processing messages (PROCESSING, WAITING, WAITING_FOR_RES) with same funnel value and for specified funnel ID.

Specified by:

getCountProcessingMessagesForFunnel in interface MessageDao

Parameters:

funnelValue - the funnel value

idleInterval - interval (in seconds) that determines how long can be message processing

funnelCompId - the funnel component ID

Returns:

count of messages

getMessagesForGuaranteedOrderForRoute

public List<Message> getMessagesForGuaranteedOrderForRoute(String funnelValue,
                                                           boolean excludeFailedState)

Description copied from interface: MessageDao

Gets list of messages with specified funnel value for guaranteed processing order of whole routes.

Specified by:

getMessagesForGuaranteedOrderForRoute in interface MessageDao

Parameters:

funnelValue - the funnel value

excludeFailedState - FAILED state is used by default; use true if you want to exclude FAILED state

Returns:

list of messages ordered by message timestamp

getMessagesForGuaranteedOrderForFunnel

public List<Message> getMessagesForGuaranteedOrderForFunnel(String funnelValue,
                                                            Duration idleInterval,
                                                            boolean excludeFailedState,
                                                            String funnelCompId)

Description copied from interface: MessageDao

Gets list of messages with specified funnel value for guaranteed processing order of messages for specified funnel.

Specified by:

getMessagesForGuaranteedOrderForFunnel in interface MessageDao

Parameters:

funnelValue - the funnel value

idleInterval - interval (in seconds) that determines how long can message be processing

excludeFailedState - FAILED state is used by default; use true if you want to exclude FAILED state

funnelCompId - the funnel component ID

Returns:

list of messages ordered by message timestamp

findMessagesByFilter

public List<Message> findMessagesByFilter(MessageFilter filter,
                                          long limit)

Description copied from interface: MessageDao

Finds messages by multiple fields, hold together in MessageFilter.

Specified by:

findMessagesByFilter in interface MessageDao

Parameters:

filter - the filter.

limit - the limit of messages.

Returns:

list of messages.

findMessagesByFilterFulltextSql

protected String findMessagesByFilterFulltextSql(String placeholder)

Fulltext SQL used with fulltext field of messageFilter in operation findMessagesByFilter. Note: it is protected, as it could be overriden.

Parameters:

placeholder - where the actual fulltext string will be.

Returns:

the sql with placeholder.