{"repo":"mateodelnorte/servicebus","free":true,"listed":false,"github":"https://github.com/mateodelnorte/servicebus","clone":"git clone https://github.com/mateodelnorte/servicebus.git","description":"Simple service bus for sending events between processes using amqp.","language":"JavaScript","stars":419,"topics":["rabbitmq","amqp","node","messaging","bus","message-bus","servicebus","service-bus","round-robin","middleware"],"license":"MIT","category":"chat-messaging","readme_excerpt":"servicebus Simple service bus for sending events between processes using amqp. Allows for send/receive and publish/subscribe pattern messaging over RabbitMQ. Configuration Sending and Receiving Servicebus allows simple sending and recieving of messages in a 1:1 sender:listener configuration. The following two processes will send an event message called 'my.event' every second from process A to process B via RabbitMQ and print out the sent event: Process A: Process B: Round-Robin Load Distribution Simply running multiple versions of Process A, above, will cause servicebus to distribute sent messages evenly accross the list of listeners, in a round-robin pattern. Message Acknowledgement (Note: message acking requires use of the https://github.com/mateodelnorte/servicebus-retry middleware) Servicebus integrates with RabbitMQ's message acknowledement functionality, which causes messages to queue instead of sending until the listening processes marks any previously received message as acknowledged or rejected. Messages can be acknowledged or rejected with the following syntax. To use ack and reject, it must be specified when defining the listening function: Message acknowledgement is suited for use in load distribution scenarios. Authentication (RabbitMQ Bus) Fully qualified url You may authenticate by providing url as an option when initializing the bus, or setting RABBITMQ URL as an environment variable. RabbitMQ uses basic auth url format for authentication. config options Alte","default_branch":null,"files":null,"tree":[],"storefront":"/r/mateodelnorte","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/mateodelnorte/servicebus/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}