Simple SAGA example using amqp and nodejs

The banks works as the following the diagram:

All the banks are listening their own queue on the broker. Everytime some transactions comes, they try to resolve it. When the transaction fail, the bank sends a compensation rolling back the transaction to the sender bank.

How to use it

Before everything, start the rabbit:

./start-rabbit.sh

to create a bank

node src/create-bank.js 
   

   

to create an account

node src/create-account.js 
   

   

to transfer between accounts

node src/transfer.js 
    
     
      
       
        
       
      
     
    
   

You can start a batch listener using

node src/batch-bank.js 
   

   

You can deposit using

node src/deposit.js 
    
     
     

     
    
   

You can withdraw using

node src/withdraw.js