Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add auto-refresh to integration daemon #8328

Merged
merged 2 commits into from
Aug 19, 2024
Merged

Add auto-refresh to integration daemon #8328

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
584dea1
Add auto-refresh to integration daemon
mandy-chessell Aug 19, 2024
a8c0669
Merge branch 'main' into oak2024
mandy-chessell Aug 19, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion CocoComboGUIDMap.json
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion CoreContentPackGUIDMap.json
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoBusinessSystemsArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoClinicalTrialsTemplatesArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoComboArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoGovernanceEngineDefinitionsArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoGovernanceProgramArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoOrganizationArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoSustainabilityArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CocoTypesArchive.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion content-packs/CoreContentPack.omarchive
View file
Open in desktop

Large diffs are not rendered by default.

4 changes: 2 additions & 2 deletions ...va/org/odpi/openmetadata/accessservices/assetmanager/handlers/ProcessExchangeHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -618,11 +618,11 @@ public void setupProcessParent(String userId,
invalidParameterHandler.validateGUID(parentProcessGUID, parentProcessGUIDParameterName, methodName);
invalidParameterHandler.validateGUID(childProcessGUID, childProcessGUIDParameterName, methodName);

int containmentTypeOrdinal = ProcessContainmentType.USED.getOpenTypeOrdinal();
int containmentTypeOrdinal = ProcessContainmentType.USED.getOrdinal();

if (containmentType != null)
{
containmentTypeOrdinal = containmentType.getOpenTypeOrdinal();
containmentTypeOrdinal = containmentType.getOrdinal();
}

processHandler.setupProcessParent(userId,
Expand Down
4 changes: 2 additions & 2 deletions ...va/org/odpi/openmetadata/accessservices/communityprofile/client/ToDoActionManagement.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -359,7 +359,7 @@ public void reassignToDo(String userId,

List<RelatedMetadataElement> assignedActors = openMetadataStoreClient.getRelatedMetadataElements(userId,
toDoGUID,
1,
2,
OpenMetadataType.ACTION_ASSIGNMENT_RELATIONSHIP_TYPE_NAME,
false,
false,
Expand All @@ -385,8 +385,8 @@ public void reassignToDo(String userId,
null,
null,
OpenMetadataType.ACTION_ASSIGNMENT_RELATIONSHIP_TYPE_NAME,
toDoGUID,
actorGUID,
toDoGUID,
false,
false,
null,
Expand Down
2 changes: 1 addition & 1 deletion ...main/java/org/odpi/openmetadata/accessservices/datamanager/ffdc/DataManagerAuditCode.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ public enum DataManagerAuditCode implements AuditLogMessageSet
* and type name {2} due to exception {3}. The error message from the exception was {4}
*/
OUTBOUND_EVENT_EXCEPTION("OMAS-DATA-MANAGER-0018",
AuditLogRecordSeverityLevel.EXCEPTION,
AuditLogRecordSeverityLevel.EVENT,
"Unable to send an outbound event of type {0} for instance with unique identifier of {1} and type name {2} due to exception {3}. The error message from the exception was {4}",
"The system detected an exception whilst attempting to send an event to the out topic. No event is sent.",
"Investigate and correct the source of the error. Once fixed, events will be sent."),
Expand Down
2 changes: 1 addition & 1 deletion ...g/odpi/openmetadata/accessservices/governanceserver/events/GovernanceServerEventType.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public enum GovernanceServerEventType
*/
REFRESH_INTEGRATION_CONNECTOR_EVENT (2,
"Refresh Integration Connector Configuration",
"The configuration for am Integration Connector has changed."),
"The configuration for an Integration Connector has changed."),


/**
Expand Down
2 changes: 1 addition & 1 deletion ...org/odpi/openmetadata/accessservices/governanceserver/ffdc/GovernanceServerAuditCode.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,7 @@ public enum GovernanceServerAuditCode implements AuditLogMessageSet
* for Governance Engine {0} ({1}) has changed
*/
REFRESH_GOVERNANCE_ENGINE("OMAS-GOVERNANCE-SERVER-0013",
AuditLogRecordSeverityLevel.INFO,
AuditLogRecordSeverityLevel.EVENT,
"The Governance Server Open Metadata Access Service (OMAS) sent notification that the configuration for Governance Engine {0} " +
"({1}) has changed",
"The access service sends out configuration notifications to ensure listening engine hosts have the most up to-date " +
Expand Down
16 changes: 16 additions & 0 deletions ...nmetadata/accessservices/governanceserver/outtopic/GovernanceServerOMRSTopicListener.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -345,6 +345,22 @@ private boolean processRegisteredIntegrationConnector(String sourceName,
{
EntityProxy integrationConnectorEntityProxy = relationship.getEntityTwoProxy();

if (integrationConnectorEntityProxy != null)
{
eventPublisher.publishRefreshIntegrationConnectorEvent(integrationConnectorEntityProxy.getGUID(),
repositoryHelper.getStringProperty(sourceName,
OpenMetadataProperty.QUALIFIED_NAME.name,
integrationConnectorEntityProxy.getUniqueProperties(),
methodName));
return true;
}
}
else if (repositoryHelper.isTypeOf(sourceName,
type.getTypeDefName(),
OpenMetadataType.CATALOG_TARGET_RELATIONSHIP_TYPE_NAME))
{
EntityProxy integrationConnectorEntityProxy = relationship.getEntityOneProxy();

if (integrationConnectorEntityProxy != null)
{
eventPublisher.publishRefreshIntegrationConnectorEvent(integrationConnectorEntityProxy.getGUID(),
Expand Down
2 changes: 1 addition & 1 deletion ...rs/data-manager-connectors/unity-catalog-connectors/UnityCatalog-demo-cataloguing-uc.http
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ Content-Type: application/json

###

@server1GUID=7af2f5a1-211b-4059-9e44-eb21e4093e96
@server1GUID=281c6358-ee6f-4009-9de9-4ef92a46f393


###
Expand Down
Loading
Loading