MassTransit-JS

MassTransit-JS copied to clipboard

Does this lib in any way support user/password to Rabbitmq?

3

Is there any way to get user+password to connect? From what I can see, RabbitMqHostAddress does not include them and there is no way to enter a connection string. Is...

petternordlanderhelo

How can I send custom/extra headers with requestClient? To clarify I mean the headers in [sendContext.ts](https://github.com/MassTransit/MassTransit-JS/blob/master/src/sendContext.ts) ``` let client = bus.requestClient({ exchange: "orders", requestType: new MessageType("SubmitOrder"), responseType: new MessageType("OrderSubmitted"), })...

lucfirely

Support for multiple transports

2

Hey just wondering if you intend to implement say azure service bus support in this?

SFSRCole

requestClient.getResponse hugs when error occurred in the consumer from the other service

1

``` @Injectable() export class OrderDetailsService { private readonly _client: RequestClient< GetOrderDetailsRequest, GetOrderDetailsResponse >; constructor(masstransit: MassTransitService) { this._client = masstransit.bus.requestClient< GetOrderDetailsRequest, GetOrderDetailsResponse >({ exchange: 'order-details', requestType: new MessageType( 'GetOrderDetailsRequest', 'Contracts.Events.OrderProcessing.Requests', ),...

dpr-dev

Steps: 1. Build masstransit-rabbitmq 2. Build and run demo Expected: 1. Create binding between intermediate and primary exchange Result: 1. No binding created I was expecting similar result as with...

leoatrenew

``` @Injectable() export class OrderDetailsService { private readonly _client: RequestClient< GetOrderDetailsRequest, GetOrderDetailsResponse >; constructor(masstransit: MassTransitService) { this._client = masstransit.bus.requestClient< GetOrderDetailsRequest, GetOrderDetailsResponse >({ exchange: 'order-details', requestType: new MessageType( 'GetOrderDetailsRequest', 'Contracts.Events.OrderProcessing.Requests', ),...

dpr-dev

I want to define an Exchange, specify its type (e.g., direct, topic, etc.), configure a Routing Key, and bind the Exchange to a Queue in receiveEndpoint. Below is my current...

nikita-vedre