Modifier and Type | Method and Description |
---|---|
static org.springframework.core.convert.converter.Converter<Message,MessageRpc> |
MessageRpc.fromMessage()
Converter to convert from Message entity.
|
static org.springframework.core.convert.converter.Converter<Message,MessageListItemRpc> |
MessageListItemRpc.fromMessage()
Convert MessageListRpc from Message entity.
|
protected static <P extends MessageBaseRpc> |
MessageBaseRpc.fromMessage(P message) |
Modifier and Type | Method and Description |
---|---|
void |
ExternalSystemConfirmation.confirm(Message msg)
Confirms the message to the external system.
|
void |
ConfirmationCallback.confirm(Message msg)
Confirms that the message was fully processed.
|
Modifier and Type | Method and Description |
---|---|
static Message |
ChildMessage.createMessage(ChildMessage childMsg)
Converts
ChildMessage into a full Message that can be persisted or processed. |
Message |
ChildMessage.getParentMessage() |
Modifier and Type | Method and Description |
---|---|
List<ChildMessage> |
MessageSplitterCallback.getChildMessages(Message parentMsg,
Object body)
Gets child messages for next processing.
|
void |
MsgSplitter.splitMessage(Message parentMsg,
Object body)
Splits specified message into smaller messages.
|
Constructor and Description |
---|
ChildMessage(Message parentMessage,
BindingTypeEnum bindingType,
ServiceExtEnum service,
String operationName,
String body,
String objectId,
EntityTypeExtEnum entityType,
String funnelValue)
Creates child message with specified binding type to parent message.
|
ChildMessage(Message parentMessage,
ServiceExtEnum service,
String operationName,
String body)
Creates child message with
HARD binding type to parent message. |
Modifier and Type | Method and Description |
---|---|
Message |
Response.getMessage()
Gets asynch.
|
Message |
Request.getMessage()
Gets asynch.
|
Message |
ExternalCall.getMessage()
Gets main asynch.
|
Modifier and Type | Method and Description |
---|---|
static ExternalCall |
ExternalCall.createFailedConfirmation(Message msg)
Creates new
failed confirmation call. |
static ExternalCall |
ExternalCall.createProcessingCall(String operationName,
String entityId,
Message msg)
Creates a new external call with
processing state. |
static Request |
Request.createRequest(String uri,
String responseJoinId,
String request,
Message msg)
Creates a new request.
|
static Response |
Response.createResponse(Request request,
String response,
String failedReason,
Message msg)
Creates a new response.
|
void |
Response.setMessage(Message message) |
void |
Request.setMessage(Message message) |
void |
ExternalCall.setMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
AbstractAsynchEvent.getMessage()
Gets asynchronous message.
|
Constructor and Description |
---|
AbstractAsynchEvent(org.apache.camel.Exchange exchange,
Message message)
Creates new event.
|
CompletedMsgAsynchEvent(org.apache.camel.Exchange exchange,
Message message)
Creates new event.
|
FailedMsgAsynchEvent(org.apache.camel.Exchange exchange,
Message message)
Creates new event.
|
PartlyFailedMsgAsynchEvent(org.apache.camel.Exchange exchange,
Message message)
Creates new event.
|
PostponedMsgAsynchEvent(org.apache.camel.Exchange exchange,
Message message)
Creates new event.
|
ProcessingMsgAsynchEvent(org.apache.camel.Exchange exchange,
Message message)
Creates new event.
|
WaitingMsgAsynchEvent(org.apache.camel.Exchange exchange,
Message message)
Creates new event.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AsynchChildProducer.insertMessage(Message msg)
Inserts new messages into DB.
|
protected void |
AsynchChildProducer.sendForNextProcessing(Message msg)
Sends message for next asynchronous processing.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
ExternalCallProducer.getMessage(org.apache.camel.Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
protected ExternalCall |
ExternalCallProducer.prepareExternalCall(String operation,
String key,
Message message,
ExternalCallService service) |
Modifier and Type | Method and Description |
---|---|
Message |
AsynchInMessageRoute.insertMessage(Message msg)
Insert new message into database.
|
Modifier and Type | Method and Description |
---|---|
void |
AsynchMessageRoute.changeStateMessageToInQueue(Message msg)
Change state of message into
MsgStateEnum.IN_QUEUE . |
boolean |
AsynchMessageRoute.checkMessageFailed(Message msg,
Exception ex)
Returns
true if failed count exceeds limit for failing. |
boolean |
AsynchMessageRoute.checkParentMessage(Message msg) |
Message |
AsynchInMessageRoute.insertMessage(Message msg)
Insert new message into database.
|
boolean |
AsynchMessageRoute.isMessageObsolete(Message msg)
Checks if current message wasn't converted to other state.
|
boolean |
AsynchInMessageRoute.isMsgInGuaranteedOrder(Message msg)
Checks if specified message should be processed in guaranteed order and if yes
then checks if the message is in the right order.
|
void |
AsynchMessageRoute.logStartProcessing(Message msg,
Long msgInsertTime) |
String |
AsynchMessageRoute.nextRoute(Message msg)
Gets URI of the next route.
|
void |
AsynchInMessageRoute.postponeMessage(org.apache.camel.Exchange exchange,
Message msg) |
ExternalCall |
ExternalCallServiceImpl.prepare(String operationUri,
String operationKey,
Message message) |
void |
AsynchInMessageRoute.saveLogContextParams(Message msg,
Map<String,Object> headers)
Saves log request ID into header
LogContextFilter.CTX_REQUEST_ID . |
void |
AsynchMessageRoute.sendMailToAdmin(Message msg)
Sends notification mail to admin(s).
|
void |
AsynchMessageRoute.setEntityInfo(Message msg,
Map<String,Object> headers)
Sets
AsynchConstants.OBJECT_ID_HEADER and AsynchConstants.ENTITY_TYPE_HEADER
headers if there are available corresponding values in message. |
static void |
LogContextHelper.setLogContextParams(Message message,
String requestId)
Set log context parameters, specifically:
LogContextFilter.CTX_SOURCE_SYSTEM
LogContextFilter.CTX_CORRELATION_ID
LogContextFilter.CTX_PROCESS_ID
LogContextFilter.CTX_REQUEST_ID
It's because child threads don't inherits this information from parent thread automatically. |
void |
AsynchMessageRoute.setLogContextParams(Message message,
String requestId)
Set log context parameters.
|
void |
AsynchInMessageRoute.setMsgPriority(Message msg) |
Modifier and Type | Method and Description |
---|---|
void |
DelegateConfirmationCallback.confirm(Message msg) |
void |
DefaultConfirmationCallback.confirm(Message msg) |
ExternalCall |
ConfirmationServiceImpl.insertFailedConfirmation(Message msg) |
ExternalCall |
ConfirmationService.insertFailedConfirmation(Message msg)
Inserts new failed confirmation.
|
Modifier and Type | Method and Description |
---|---|
Message |
MessageTransformer.createMessage(org.apache.camel.Exchange exchange,
TraceHeader traceHeader,
String payload,
ServiceExtEnum service,
String operationName,
String objectId,
EntityTypeExtEnum entityType,
String funnelValue,
Boolean guaranteedOrder,
Boolean excludeFailedState)
Creates message entity.
|
Message |
MessageServiceImpl.findEagerMessageById(Long msgId) |
Message |
MessageServiceImpl.findMessageById(Long msgId) |
Message |
MessageServiceImpl.findPartlyFailedMessage(Duration interval) |
Message |
MessageServiceImpl.findPostponedMessage(Duration interval) |
Modifier and Type | Method and Description |
---|---|
List<Message> |
MessageServiceImpl.findMessagesByFilter(MessageFilter messageFilter,
long limit) |
List<Message> |
MessageServiceImpl.getMessagesForGuaranteedOrderForFunnel(String funnelValue,
Duration idleInterval,
boolean excludeFailedState,
String funnelCompId) |
List<Message> |
MessageServiceImpl.getMessagesForGuaranteedOrderForRoute(String funnelValue,
boolean excludeFailedState) |
Modifier and Type | Method and Description |
---|---|
static List<MessageActionType> |
MessageHelper.allowedActions(Message message)
Get allowed actions for message.
|
void |
MessageServiceImpl.insertMessage(Message message) |
void |
MessageServiceImpl.setFunnelComponentId(Message msg,
String funnelCompId) |
void |
MessageServiceImpl.setStateFailed(Message msg,
ErrorExtEnum errCode,
String errDesc) |
void |
MessageServiceImpl.setStateFailed(Message msg,
Exception ex,
ErrorExtEnum errCode,
String customData,
Map<String,Object> props) |
boolean |
MessageServiceImpl.setStateInQueueForLock(Message message) |
void |
MessageServiceImpl.setStateOk(Message msg,
Map<String,Object> props) |
void |
MessageServiceImpl.setStatePartlyFailed(Message msg,
Exception ex,
ErrorExtEnum errCode,
String customData,
Map<String,Object> props) |
void |
MessageServiceImpl.setStatePartlyFailedWithoutError(Message msg) |
void |
MessageServiceImpl.setStatePostponed(Message msg) |
void |
MessageServiceImpl.setStateProcessing(Message msg) |
boolean |
MessageServiceImpl.setStateProcessingForLock(Message message) |
void |
MessageServiceImpl.setStateWaiting(Message msg) |
void |
MessageServiceImpl.setStateWaitingForResponse(Message msg) |
void |
MessageSplitterImpl.splitMessage(Message parentMsg,
Object body) |
static void |
MessageHelper.updateBusinessErrors(Message msg,
Map<String,Object> properties)
Checks the properties for those that end with
AsynchConstants.BUSINESS_ERROR_PROP_SUFFIX
and moves the found exceptions to the Message's business error list, subsequently returning it. |
Modifier and Type | Method and Description |
---|---|
void |
MessageServiceImpl.insertMessages(Collection<Message> messages) |
Modifier and Type | Method and Description |
---|---|
Message |
MessagesPoolImpl.getNextMessage() |
Message |
MessagesPool.getNextMessage()
Gets message for next processing.
|
Modifier and Type | Method and Description |
---|---|
Message |
MessageDaoJpaImpl.findByCorrelationId(String correlationId,
ExternalSystemExtEnum sourceSystem) |
Message |
MessageDao.findByCorrelationId(String correlationId,
ExternalSystemExtEnum sourceSystem)
Finds message by source system and correlation ID.
|
Message |
MessageDaoJpaImpl.findEagerMessage(Long msgId) |
Message |
MessageDao.findEagerMessage(Long msgId)
Finds message by its ID with eager loading.
|
Message |
MessageDaoJpaImpl.findMessage(Long msgId) |
Message |
MessageDao.findMessage(Long msgId)
Finds message by its ID.
|
Message |
MessageDaoJpaImpl.findPartlyFailedMessage(Duration interval) |
Message |
MessageDao.findPartlyFailedMessage(Duration interval)
Finds ONE message in state
MsgStateEnum.PARTLY_FAILED . |
Message |
MessageDaoJpaImpl.findPostponedMessage(Duration interval) |
Message |
MessageDao.findPostponedMessage(Duration interval)
Finds ONE message in state
MsgStateEnum.POSTPONED . |
Message |
MessageDaoJpaImpl.getMessage(Long msgId) |
Message |
MessageDao.getMessage(Long msgId)
Gets message by its ID.
|
Modifier and Type | Method and Description |
---|---|
List<Message> |
MessageDaoJpaImpl.findChildMessages(Message msg) |
List<Message> |
MessageDao.findChildMessages(Message msg)
Finds all child messages of specified parent message.
|
List<Message> |
MessageDaoJpaImpl.findChildMessagesForParent(Message parentMessage) |
List<Message> |
MessageDao.findChildMessagesForParent(Message parentMessage)
Finds all child message for parent message.
|
List<Message> |
MessageDaoJpaImpl.findMessagesByFilter(MessageFilter filter,
long limit) |
List<Message> |
MessageDao.findMessagesByFilter(MessageFilter messageFilter,
long limit)
Finds messages by multiple fields, hold together in MessageFilter.
|
List<Message> |
MessageDaoJpaImpl.findProcessingMessages(Duration interval) |
List<Message> |
MessageDao.findProcessingMessages(Duration interval)
Finds processing messages to repair process.
|
List<Message> |
MessageDaoJpaImpl.getMessagesForGuaranteedOrderForFunnel(String funnelValue,
Duration idleInterval,
boolean excludeFailedState,
String funnelCompId) |
List<Message> |
MessageDao.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> |
MessageDaoJpaImpl.getMessagesForGuaranteedOrderForRoute(String funnelValue,
boolean excludeFailedState) |
List<Message> |
MessageDao.getMessagesForGuaranteedOrderForRoute(String funnelValue,
boolean excludeFailedState)
Gets list of messages with specified funnel value for guaranteed processing order of whole routes.
|
Modifier and Type | Method and Description |
---|---|
List<Message> |
MessageDaoJpaImpl.findChildMessages(Message msg) |
List<Message> |
MessageDao.findChildMessages(Message msg)
Finds all child messages of specified parent message.
|
List<Message> |
MessageDaoJpaImpl.findChildMessagesForParent(Message parentMessage) |
List<Message> |
MessageDao.findChildMessagesForParent(Message parentMessage)
Finds all child message for parent message.
|
void |
MessageDaoJpaImpl.insert(Message msg) |
void |
MessageDao.insert(Message msg)
Inserts new message.
|
void |
MessageOperationDaoJpaImpl.removeExtCalls(Message msg,
boolean totalRestart) |
void |
MessageOperationDao.removeExtCalls(Message msg,
boolean totalRestart)
Removes external calls for specific message.
|
boolean |
MessageOperationDaoJpaImpl.setCancelState(Message msg) |
boolean |
MessageOperationDao.setCancelState(Message msg)
Cancels next message processing = change the message state to
MsgStateEnum.CANCEL . |
boolean |
MessageOperationDaoJpaImpl.setPartlyFailedState(Message msg) |
boolean |
MessageOperationDao.setPartlyFailedState(Message msg)
Restarts message = change the message state from FAILED -> PARTLY_FAILED.
|
void |
MessageDaoJpaImpl.update(Message msg) |
void |
MessageDao.update(Message msg)
Updates message.
|
boolean |
MessageDaoJpaImpl.updateMessageInQueueUnderLock(Message msg,
Node processingNode) |
boolean |
MessageDao.updateMessageInQueueUnderLock(Message msg,
Node processingNode)
Updates
Message into state MsgStateEnum.IN_QUEUE (set start timestamp in queue)
- gets lock for message. |
boolean |
MessageDaoJpaImpl.updateMessageProcessingUnderLock(Message msg,
Node processingNode) |
boolean |
MessageDao.updateMessageProcessingUnderLock(Message msg,
Node processingNode)
Updates
Message into state MsgStateEnum.PROCESSING (set start timestamp of processing)
- gets lock for message. |
Modifier and Type | Method and Description |
---|---|
ExternalCall |
ExternalCallService.prepare(String operationUri,
String operationKey,
Message message)
Prepares a new external call for the specified unique operation invocation.
|
Modifier and Type | Method and Description |
---|---|
Message |
MessageService.findEagerMessageById(Long msgId)
Finds message by message ID with eager loading.
|
Message |
MessageService.findMessageById(Long msgId)
Finds message by message ID.
|
Message |
MessageService.findPartlyFailedMessage(Duration interval)
Finds ONE message in state
MsgStateEnum.PARTLY_FAILED . |
Message |
MessageService.findPostponedMessage(Duration interval)
Finds ONE message in state
MsgStateEnum.POSTPONED . |
Modifier and Type | Method and Description |
---|---|
List<Message> |
MessageService.findMessagesByFilter(MessageFilter messageFilter,
long limit)
Finds list of messages that match with given filter.
|
List<Message> |
MessageService.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> |
MessageService.getMessagesForGuaranteedOrderForRoute(String funnelValue,
boolean excludeFailedState)
Gets list of messages with specified funnel value for guaranteed processing order of whole routes.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageService.insertMessage(Message message)
Inserts new message.
|
void |
MessageService.setFunnelComponentId(Message msg,
String funnelCompId)
Sets funnel component identifier to specified message.
|
void |
MessageService.setStateFailed(Message msg,
ErrorExtEnum errCode,
String errDesc)
Changes state of the message to
MsgStateEnum.FAILED . |
void |
MessageService.setStateFailed(Message msg,
Exception ex,
ErrorExtEnum errCode,
String customData,
Map<String,Object> props)
Changes state of the message to
MsgStateEnum.FAILED . |
boolean |
MessageService.setStateInQueueForLock(Message message)
Set state
MsgStateEnum.IN_QUEUE on Message under database lock. |
void |
MessageService.setStateOk(Message msg,
Map<String,Object> props)
Changes state of the message to
MsgStateEnum.OK . |
void |
MessageService.setStatePartlyFailed(Message msg,
Exception ex,
ErrorExtEnum errCode,
String customData,
Map<String,Object> props)
Changes state of the message to
MsgStateEnum.PARTLY_FAILED . |
void |
MessageService.setStatePartlyFailedWithoutError(Message msg)
Changes state of the message to
MsgStateEnum.PARTLY_FAILED but without increasing error count. |
void |
MessageService.setStatePostponed(Message msg)
Changes state of the message to
MsgStateEnum.POSTPONED . |
void |
MessageService.setStateProcessing(Message msg)
Changes state of the message to
MsgStateEnum.PROCESSING . |
boolean |
MessageService.setStateProcessingForLock(Message message)
Set state
MsgStateEnum.PROCESSING on Message under database lock. |
void |
MessageService.setStateWaiting(Message msg)
Changes state of the message to
MsgStateEnum.WAITING - only if the message hasn't been already processed. |
void |
MessageService.setStateWaitingForResponse(Message msg)
Changes state of the message to
MsgStateEnum.WAITING_FOR_RES . |
Modifier and Type | Method and Description |
---|---|
void |
MessageService.insertMessages(Collection<Message> messages)
Inserts new messages.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
AbstractDbTest.createAndSaveMessage(ExternalSystemExtEnum sourceSystem,
ServiceExtEnum service,
String operationName,
String payload)
Creates and saves new message.
|
protected Message[] |
AbstractDbTest.createAndSaveMessages(int messageCount,
AbstractDbTest.MessageCallback messageCallback)
Creates and saves new messages.
|
protected Message[] |
AbstractDbTest.createAndSaveMessages(int messageCount,
ExternalSystemExtEnum sourceSystem,
ServiceExtEnum service,
String operationName,
String payload)
Creates and saves new messages.
|
protected Message |
AbstractDbTest.createMessage(ExternalSystemExtEnum sourceSystem,
ServiceExtEnum service,
String operationName,
String payload)
Creates new message (without saving into database).
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractDbTest.MessageCallback.beforeInsert(Message message,
int order)
Do whatever you want before the message will be inserted into database
|
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.