-
Notifications
You must be signed in to change notification settings - Fork 77
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Implemented RoutingKey functionality for REMREM Semantics (#65)
* Implemented RoutingKey functionality for REMREM Semantics * Added json files and modified testcases * Handled null condition of RoutingKey
- Loading branch information
1 parent
7f8e1b9
commit 81ec0c4
Showing
12 changed files
with
463 additions
and
24 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
38 changes: 38 additions & 0 deletions
38
publish-service/src/integration-test/resources/EiffelActivityFinishedEvent.json
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,38 @@ | ||
| { | ||
| "data": { | ||
| "outcome": { | ||
| "conclusion": "TIMED_OUT", | ||
| "description": "Compilation timed out." | ||
| }, | ||
| "persistentLogs": [{ | ||
| "name": "firstLog", | ||
| "uri": "http://myHost.com/firstLog" | ||
| }, { | ||
| "name": "otherLog", | ||
| "uri": "isbn:0-486-27557-4" | ||
| }] | ||
| }, | ||
| "links": { | ||
| "activityExecution": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeee1", | ||
| "flowContext": "flowContext", | ||
| "causes": ["cause1", "cause2"] | ||
| }, | ||
| "meta": { | ||
| "domainId": "TCS", | ||
| "id": "1afffd13-04ae-4638-97f1-aaeed78a28c7", | ||
| "type": "eiffelactivityfinished", | ||
| "version": "0.1.8", | ||
| "time": 1481628758807, | ||
| "tags": ["tag1", "tag2"], | ||
| "source": { | ||
| "host": "host", | ||
| "name": "name", | ||
| "uri": "http://java.sun.com/j2se/1.3/", | ||
| "serializer": { | ||
| "groupId": "G", | ||
| "artifactId": "A", | ||
| "version": "V" | ||
| } | ||
| } | ||
| } | ||
| } |
47 changes: 47 additions & 0 deletions
47
publish-service/src/integration-test/resources/EiffelJobFinishedEvent.json
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,47 @@ | ||
| { | ||
| "eiffelMessageVersions": { | ||
| "3.21.42.0.4": { | ||
| "domainId": "eiffel010.generator", | ||
| "eventId": "2930b40e-79dc-453c-b178-bc2bbde593ba", | ||
| "eventTime": "2016-12-09T05:05:27.797Z", | ||
| "eventType": "EiffelJobFinishedEvent", | ||
| "inputEventIds": [ | ||
| "5034777a-6f25-409e-abd2-39e592158c7f" | ||
| ], | ||
| "eventData": { | ||
| "jobInstance": "MessageGenerator", | ||
| "jobExecutionId": "114ad8ae-3f18-48bf-a672-2b068236845e", | ||
| "jobExecutionNumber": 24999, | ||
| "resultCode": "SUCCESS", | ||
| "logReferences": { | ||
|
|
||
| }, | ||
| "flowContext": "", | ||
| "optionalParameters": { | ||
| "COUNT": "99995" | ||
| } | ||
| } | ||
| }, | ||
| "2.3.42.0.4": { | ||
| "domainId": "eiffel010.generator", | ||
| "eventId": "2930b40e-79dc-453c-b178-bc2bbde593ba", | ||
| "eventTime": "2016-12-09T05:05:27.797Z", | ||
| "eventType": "EiffelJobFinishedEvent", | ||
| "inputEventIds": [ | ||
| "5034777a-6f25-409e-abd2-39e592158c7f" | ||
| ], | ||
| "eventData": { | ||
| "jobInstance": "MessageGenerator", | ||
| "jobExecutionId": "114ad8ae-3f18-48bf-a672-2b068236845e", | ||
| "jobExecutionNumber": 24999, | ||
| "resultCode": "SUCCESS", | ||
| "logReferences": { | ||
|
|
||
| }, | ||
| "optionalParameters": { | ||
| "COUNT": "99995" | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } |
37 changes: 37 additions & 0 deletions
37
publish-service/src/integration-test/resources/Invalid_EiffelActivityFinishedEvent.json
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,37 @@ | ||
| { | ||
| "data": { | ||
| "outcome": { | ||
| "conclusion": "TIMED_OUT", | ||
| "description": "Compilation timed out." | ||
| }, | ||
| "persistentLogs": [{ | ||
| "name": "firstLog", | ||
| "uri": "http://myHost.com/firstLog" | ||
| }, { | ||
| "name": "otherLog", | ||
| "uri": "isbn:0-486-27557-4" | ||
| }] | ||
| }, | ||
| "links": { | ||
| "activityExecution": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeee1", | ||
| "flowContext": "flowContext", | ||
| "causes": ["cause1", "cause2"] | ||
| }, | ||
| "meta": { | ||
| "domainId": "example.domain", | ||
| "type": "eiffelactivityfinished", | ||
| "version": "0.1.7", | ||
| "time": 1478780245184, | ||
| "tags": ["tag1", "tag2"], | ||
| "source": { | ||
| "host": "host", | ||
| "name": "name", | ||
| "uri": "http://java.sun.com/j2se/1.3/", | ||
| "serializer": { | ||
| "groupId": "G", | ||
| "artifactId": "A", | ||
| "version": "V" | ||
| } | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.