The borndigital-poller from viaacode

Update/enhance documentation

Update synopsis and add description (should be more accurate)
What starts this flow? Quartz or queue? If queue: what is the exact queue name?
Make high-level overview graph (draw.io, Gliffy, ...) (examples here: https://github.com/maartends/Charts)
Make roles/handles link to users
Make stack components link to external source (Mule CE)
Expand logging: where will the log files end up?
...
Finally, can this application be cloned and run based on the documentation?

Remove events from application

The events-functionality will be obsoleted by the native MH-events in v19.3, and can be removed from the borndigital-poller.

borndigital-poller/src/main/app/borndigital-poller.xml

Lines 160 to 220 in f3526c2

 <flow name="CheckArchive_statusFlow"> 

 <choice doc:name="Did archive_status change?"> 

 <when expression="#[flowVars.file.archive_status.toLowerCase() != flowVars.mh_result.archive_status.toLowerCase()]"> 

 <logger message="[#[flowVars.file.pid]]: Sending status message to Connector Poller" level="INFO" doc:name="Log: Archive status changed, sending status message"/> 

 <scripting:component doc:name="create status message"> 

 <scripting:script engine="Groovy"><![CDATA[def builder = new groovy.json.JsonBuilder() 

 def root = builder { 

  "local_record" { 

  id flowVars.file.id 

  local_id flowVars.file.local_id 

  md5 flowVars.file.md5 

  pid flowVars.file.pid 

  organisation flowVars.file.organisation 

  filename flowVars.file.filename 

  filepath flowVars.file.filepath 

  host flowVars.file.host 

  is_deleted flowVars.file.is_deleted 

  comment flowVars.file.comment 

  last_event_date flowVars.file.last_event_date 

  retry_count flowVars.file.retry_count 

  reported flowVars.file.reported 

  organisation_id flowVars.file.organisation_id 

  } 

  "archive_status" { 

  previous flowVars.file.archive_status 

  current flowVars.mh_result.archive_status 

  } 

  "remote_record" { 

  pid flowVars.mh_result.external_id 

  organisation flowVars.mh_result.organisation 

  archive_status flowVars.mh_result.archive_status 

  id flowVars.mh_result.id 

  local_id flowVars.mh_result.local_id 

  md5 flowVars.mh_result.md5 

  filename flowVars.mh_result.filename 

  filepath flowVars.mh_result.filepath 

  host flowVars.mh_result.host 

  on_tape flowVars.mh_result.on_tape 

  is_deleted flowVars.mh_result.is_deleted 

  comment flowVars.file.comment 

  last_event_date flowVars.mh_result.last_event_date 

  retry_count flowVars.mh_result.retry_count 

  reported flowVars.mh_result.reported 

  organisation_id flowVars.mh_result.organisation_id 

  } 

 } 

 return builder.toPrettyString() 

 ]]></scripting:script> 

 </scripting:component> 

 <amqp:outbound-endpoint exchangeName="borndigital_poller_events" queueName="borndigital_poller_events" routingKey="borndigital.poller.events" exchangeType="topic" queueDurable="true" responseTimeout="10000" mimeType="application/json" connector-ref="RabbitMQConnectorPoller" doc:name="Send status message"/> 

 </when> 

 <otherwise> 

 <logger message="[#[flowVars.file.pid]]: 'archive_status' did not change" level="INFO" doc:name="Log: 'archive_status' did not change"/> 

 </otherwise> 

 </choice> 

 <catch-exception-strategy doc:name="Catch Exception Strategy"> 

 <logger message="[#[flowVars.file.pid]]: Failed to send status message to borndigital_poller_events" level="ERROR" doc:name="Log: Failed to send status message to borndigital_poller_events"/> 

 </catch-exception-strategy> 

 </flow>

viaacode / borndigital-poller Goto Github PK

borndigital-poller's People

Contributors

Watchers

borndigital-poller's Issues

Update/enhance documentation

Add master branch (PRD)

Add event queue

Remove events from application

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent

	<flow name="CheckArchive_statusFlow">
	<choice doc:name="Did archive_status change?">
	<when expression="#[flowVars.file.archive_status.toLowerCase() != flowVars.mh_result.archive_status.toLowerCase()]">
	<logger message="[#[flowVars.file.pid]]: Sending status message to Connector Poller" level="INFO" doc:name="Log: Archive status changed, sending status message"/>
	<scripting:component doc:name="create status message">
	<scripting:script engine="Groovy"><![CDATA[def builder = new groovy.json.JsonBuilder()

	def root = builder {
	"local_record" {
	id flowVars.file.id
	local_id flowVars.file.local_id
	md5 flowVars.file.md5
	pid flowVars.file.pid
	organisation flowVars.file.organisation
	filename flowVars.file.filename
	filepath flowVars.file.filepath
	host flowVars.file.host
	is_deleted flowVars.file.is_deleted
	comment flowVars.file.comment
	last_event_date flowVars.file.last_event_date
	retry_count flowVars.file.retry_count
	reported flowVars.file.reported
	organisation_id flowVars.file.organisation_id
	}
	"archive_status" {
	previous flowVars.file.archive_status
	current flowVars.mh_result.archive_status
	}
	"remote_record" {
	pid flowVars.mh_result.external_id
	organisation flowVars.mh_result.organisation
	archive_status flowVars.mh_result.archive_status
	id flowVars.mh_result.id
	local_id flowVars.mh_result.local_id
	md5 flowVars.mh_result.md5
	filename flowVars.mh_result.filename
	filepath flowVars.mh_result.filepath
	host flowVars.mh_result.host
	on_tape flowVars.mh_result.on_tape
	is_deleted flowVars.mh_result.is_deleted
	comment flowVars.file.comment
	last_event_date flowVars.mh_result.last_event_date
	retry_count flowVars.mh_result.retry_count
	reported flowVars.mh_result.reported
	organisation_id flowVars.mh_result.organisation_id
	}
	}

	return builder.toPrettyString()
	]]></scripting:script>
	</scripting:component>
	<amqp:outbound-endpoint exchangeName="borndigital_poller_events" queueName="borndigital_poller_events" routingKey="borndigital.poller.events" exchangeType="topic" queueDurable="true" responseTimeout="10000" mimeType="application/json" connector-ref="RabbitMQConnectorPoller" doc:name="Send status message"/>
	</when>
	<otherwise>
	<logger message="[#[flowVars.file.pid]]: 'archive_status' did not change" level="INFO" doc:name="Log: 'archive_status' did not change"/>
	</otherwise>
	</choice>
	<catch-exception-strategy doc:name="Catch Exception Strategy">
	<logger message="[#[flowVars.file.pid]]: Failed to send status message to borndigital_poller_events" level="ERROR" doc:name="Log: Failed to send status message to borndigital_poller_events"/>
	</catch-exception-strategy>
	</flow>