Skip to content

Commit

Permalink
Update claw-data-flow.md
Browse files Browse the repository at this point in the history
  • Loading branch information
Natkeeran authored Nov 15, 2017
1 parent dbb4a2d commit 763018c
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions claw-data-flow.md
Original file line number Diff line number Diff line change
@@ -1,11 +1,14 @@
![alt text](CLAW%20Data%20Flow.jpg)

* User creates a node in Drupal.

* Drupal Rules get executed (`islandora/src/Plugin/RulesAction/Broadcaster.php`) and a create event message gets posted to the `islandora-indexing-fcrepo-content` queue in the ActiveMQ. Sample Message:
* Drupal Rules get executed (`islandora/src/Plugin/RulesAction/Broadcaster.php`) and a create event message gets posted to the `islandora-indexing-fcrepo-content` queue in the ActiveMQ. Another message is posted to the `islandora-indexing-triplestore-index` queue.

```
IslandoraBroadcastRecipients:activemq\cqueue\cislandora-indexing-fcrepo-create,activemq\cqueue\cislandora-indexing-triplestore Authorization:Bearer Authorization Token @"@context":"https:\/\/www.w3.org\/ns\/activitystreams","type":"Create","actor":{"type":"Person","id":"http:\/\/dsu-beta.utsc.utoronto.ca:8000\/user\/1","object":"http:\/\/dsu-beta.utsc.utoronto.ca:8000\/node\/49"}
```

* Alpaca islandora-indexing-fcrepo picks up the message from the `islandora-indexing-fcrepo-content` queue and invokes Milliner microservice (FcrepoIndexer.java). Note that `content.stream` is mapped to `islandora-indexing-fcrepo-content` in the Alpaca config.
* Alpaca islandora-indexing-fcrepo picks up the message from the `islandora-indexing-fcrepo-content` queue and invokes Milliner microservice in FcrepoIndexer.java. Note that `content.stream` is mapped to `islandora-indexing-fcrepo-content` in the Alpaca config.

```java
from("{{content.stream}}")
Expand All @@ -19,4 +22,5 @@ IslandoraBroadcastRecipients:activemq\cqueue\cislandora-indexing-fcrepo-create,a
* Alpaca islandora-indexing-triplestore picks up the message and uses SparqlUpdateProcessor to index it in Blazegraph.

* Milliner creates a resource in Fedora.

* Gemini provides path mapping service for Milliner.

0 comments on commit 763018c

Please sign in to comment.