LandRegistry/register-publisher

Name: register-publisher

Owner: HM Land Registry

Description: takes messages from the land register queue and forwards to the feeder queue

Created: 2015-02-12 13:13:59.0

Updated: 2016-02-05 12:28:10.0

Pushed: 2016-03-11 14:40:36.0

Homepage: null

Size: 160

Language: Python

GitHub Committers

User	Most Recent Commit	# Commits

Other Committers

User	Email	Most Recent Commit	# Commits

README

Register publisher

Beta version of the “Register Publisher”.

This service will forward messages from the “System of Record” queue to the “feeder” queue.

• Using the Advanced Message Queuing Protocol (AMQP).
• Messages are received via the default 'direct' exchange.
• They are forwarded to the default 'fanout' exchange - which permits multiple clients.
• A 'direct' type of output exchange should also be possible but may have to be explicitly set.

See the wiki for design notes, etc.

Dependencies:

• See 'requirements.txt'; in particular, additions for 'kombu' and 'stopit'.
• “RabbitMQ”, an AMQP broker.
• A suitable non-guest account for the above, when using more than one machine (even a virtual one).

environment

This application refers to the following environment variables:

|Name | Default 'Config' Value |Mandatory?| | ————- |————-| —–| |SETTINGS |“config.DevelopmentConfig” |YES| |LOG_THRESHOLD_LEVEL |ERROR |NO| |RP_HOSTNAME |“amqp://guest:guest@localhost:5672//” |NO| |INCOMING_QUEUE |“INCOMING_QUEUE” |NO| |OUTGOING_QUEUE |“OUTGOING_QUEUE” |NO|

N.B.:
Even though some of the environment variables are not required, the corresponding 'config' values will be set.
In particular, the default 'RP_HOSTNAME' value is for development purposes only and the e.v. should be set as appropriate.

Prerequisites

• Account with necessary privileges needs to be created; default RabbitMQ 'guest' account is restricted to localhost use only.

how to run in development

N.B.: for a Windows host m/c:

git config --global core.autocrlf false

Then use 'Git Bash' console.

Also, for 'vagrant' operation, ensure that “VBoxHeadless.exe” is added to the firewall rules ('private').

ant up
ant ssh

Supervisord has been configured to launch this application on start up, but if you want to stop Supervisord running it and run it yourself then:

 supervisorctl stop register-publisher
n.sh

Query the queue counts

 http://0.0.0.0:5009/outgoingcount

 http://0.0.0.0:5009/incomingcount

how to run tests

In virtual machine ('vagrant'):

• use IP address of host m/c (for Windows, at least).
• in that case the RabbitMQ 'guest' account may not be sufficient.

if executing tests directly on host:

• 'localhost' will be required
• default RabbitMQ 'guest' account will suffice.

st.sh

How to manage rabbitmq:

Status of the server

ice rabbitmq-server status

Stop the server

ice rabbitmq-server stop

Start the server

ice rabbitmq-server start

Add a test message

itmqadmin publish exchange=amq.default routing_key=register-publisher payload="hello, world"

itmqadmin publish exchange=amq.default routing_key=system_of_record payload="hello, world"

Audit Requirements

From “Audit Requirements for the Migration Process”:

Activities to be logged:

• Pulls from System of Record queue
• Acknowledges pull
• Pushes to the Register Publisher queue
• Acknowledges successful receipt by Register Publisher queue.