Package | Description |
---|---|
org.openhubframework.openhub.admin.web.message.rpc | |
org.openhubframework.openhub.api.entity |
Main (business) entities.
|
org.openhubframework.openhub.component.externalcall |
"extcall" component implementation.
|
org.openhubframework.openhub.core.common.asynch |
Processing of asynchronous messages.
|
org.openhubframework.openhub.core.common.asynch.confirm |
Confirmation functionality.
|
org.openhubframework.openhub.core.common.dao |
DAO classes.
|
org.openhubframework.openhub.spi.extcall |
Modifier and Type | Method and Description |
---|---|
static org.springframework.core.convert.converter.Converter<ExternalCall,ExternalCallInfoRpc> |
ExternalCallInfoRpc.fromExternalCall() |
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. |
Modifier and Type | Method and Description |
---|---|
List<ExternalCall> |
Message.getExternalCalls()
Gets the set of referenced external calls.
|
Modifier and Type | Method and Description |
---|---|
protected ExternalCall |
ExternalCallProducer.prepareExternalCall(String operation,
String key,
Message message,
ExternalCallService service) |
Modifier and Type | Method and Description |
---|---|
protected void |
ExternalCallProducer.finalizeExternalCall(org.apache.camel.Exchange exchange,
ExternalCall externalCall,
ExternalCallService service) |
Modifier and Type | Method and Description |
---|---|
ExternalCall |
ExternalCallServiceImpl.prepare(String operationUri,
String operationKey,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
ExternalCallServiceImpl.complete(ExternalCall extCall) |
void |
ExternalCallServiceImpl.failed(ExternalCall extCall) |
Modifier and Type | Method and Description |
---|---|
ExternalCall |
ConfirmationPoolDbImpl.getNextConfirmation() |
ExternalCall |
ConfirmationPool.getNextConfirmation()
Gets confirmation for next processing.
|
ExternalCall |
ConfirmationServiceImpl.insertFailedConfirmation(Message msg) |
ExternalCall |
ConfirmationService.insertFailedConfirmation(Message msg)
Inserts new failed confirmation.
|
Modifier and Type | Method and Description |
---|---|
void |
ConfirmationServiceImpl.confirmationComplete(ExternalCall extCall) |
void |
ConfirmationService.confirmationComplete(ExternalCall externalCall)
Marks confirmation as successfully completed.
|
void |
ConfirmationServiceImpl.confirmationFailed(ExternalCall extCall) |
void |
ConfirmationService.confirmationFailed(ExternalCall externalCall)
Marks confirmation as successfully completed.
|
Modifier and Type | Method and Description |
---|---|
ExternalCall |
ExternalCallDaoJpaImpl.findConfirmation(Duration interval) |
ExternalCall |
ExternalCallDao.findConfirmation(Duration interval)
Finds ONE confirmation in state
ExternalCallStateEnum.FAILED . |
ExternalCall |
ExternalCallDaoJpaImpl.getExternalCall(String operationName,
String entityId) |
ExternalCall |
ExternalCallDao.getExternalCall(String operationName,
String entityId)
Finds an existing external call for the specified operation and entityId.
|
ExternalCall |
ExternalCallDaoJpaImpl.lockConfirmation(ExternalCall extCall) |
ExternalCall |
ExternalCallDao.lockConfirmation(ExternalCall extCall)
Updates confirmation (set state to PROCESSING) - gets lock for this confirmation.
|
Modifier and Type | Method and Description |
---|---|
List<ExternalCall> |
ExternalCallDaoJpaImpl.findProcessingExternalCalls(Duration interval) |
List<ExternalCall> |
ExternalCallDao.findProcessingExternalCalls(Duration interval)
Finds "processing" external calls in specified interval.
|
Modifier and Type | Method and Description |
---|---|
void |
ExternalCallDaoJpaImpl.insert(ExternalCall externalCall) |
void |
ExternalCallDao.insert(ExternalCall externalCall)
Inserts new call.
|
ExternalCall |
ExternalCallDaoJpaImpl.lockConfirmation(ExternalCall extCall) |
ExternalCall |
ExternalCallDao.lockConfirmation(ExternalCall extCall)
Updates confirmation (set state to PROCESSING) - gets lock for this confirmation.
|
void |
ExternalCallDaoJpaImpl.lockExternalCall(ExternalCall extCall) |
void |
ExternalCallDao.lockExternalCall(ExternalCall extCall)
Updates the specified attached external call entity to
start processing a new external call (set state to PROCESSING).
|
void |
ExternalCallDaoJpaImpl.update(ExternalCall externalCall) |
void |
ExternalCallDao.update(ExternalCall externalCall)
Updates call.
|
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 |
---|---|
void |
ExternalCallService.complete(ExternalCall externalCall)
Marks the external call as a successfully executed call.
|
void |
ExternalCallService.failed(ExternalCall externalCall)
Marks the external call as an unsuccessfully executed call.
|
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.