An adapter service to translate inbound PubSub messages into the standard format of RM JSON events and republish them on to our events exchange.
Requires golang >= 1.13 installed
The required environment configuration variables are:
RABBIT_HOST
RABBIT_PORT
RABBIT_USERNAME
RABBIT_PASSWORD
EQ_RECEIPT_PROJECT
OFFLINE_RECEIPT_PROJECT
QM_UNDELIVERED_SUBSCRIPTION_PROJECT
PPO_UNDELIVERED_SUBSCRIPTION_PROJECT
QUARANTINE_MESSAGE_URLLOG_LEVEL=DEBUG
RABBIT_HOST=localhost
RABBIT_PORT=7672
RABBIT_USERNAME=guest
RABBIT_PASSWORD=guest
EQ_RECEIPT_PROJECT=project
PUBSUB_EMULATOR_HOST=localhost:8539
EQ_RECEIPT_PROJECT=project
OFFLINE_RECEIPT_PROJECT=offline-project
QM_UNDELIVERED_SUBSCRIPTION_PROJECT=qm-undelivered-project
PPO_UNDELIVERED_SUBSCRIPTION_PROJECT=ppo-undelivered-project
RECEIPT_ROUTING_KEY=goTestReceiptQueue
UNDELIVERED_ROUTING_KEY=goTestUndeliveredQueue
FULFILMENT_CONFIRMED_PROJECT=fulfilment-project
QUARANTINE_MESSAGE_URL=http://httpbin.org/post
RABBIT_EXCHANGE=NB: RABBIT_EXCHANGE is intentionally an empty string to use the rabbit default exchange
LOG_LEVEL=INFO
RABBIT_HOST=localhost
RABBIT_PORT=6672
RABBIT_USERNAME=guest
RABBIT_PASSWORD=guest
EQ_RECEIPT_PROJECT=project
PUBSUB_EMULATOR_HOST=localhost:8538
EQ_RECEIPT_PROJECT=project
OFFLINE_RECEIPT_PROJECT=offline-project
QM_UNDELIVERED_SUBSCRIPTION_PROJECT=qm-undelivered-project
PPO_UNDELIVERED_SUBSCRIPTION_PROJECT=ppo-undelivered-project
FULFILMENT_CONFIRMED_PROJECT=fulfilment-confirmed-project
QUARANTINE_MESSAGE_URL=http://localhost:8666/storeskippedmessageRun
make build-testThis will run the formatter, build and units tests then spin up the dependencies with docker-compose and run the service integration tests.
To run the integration tests in an IDE
- Run
make up-dependenciesto start up the dependencies with docker-compose. - Set the environment variable
PUBSUB_EMULATOR_HOST=localhost:8539in your IDE run configuration - Run the test in debug mode
Run make format to automatically format the project using gofmt
With
make dockerRun make up to start the pubsub-adapter and dependencies through docker-compose
You can then run make logs to tail the logs
You can send a test message onto the pubsub emulator with the tools script
PUBSUB_EMULATOR_HOST=localhost:8539 go run tools/publish_message.goYou should see the pubsub adapter log that it has processed the message and see the rabbit messages it produced in the rabbit management UI at http://localhost:17672 (login: guest, guest).
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent