Allen Hartwig

Same problem here. It would be great to have a 'ready' event for the worker so we know when we can begin posting data to it... or have the createWorker...

I'm finding that I need a timeout upwards of 1000ms otherwise if `worker.postMessage(...)` is called from within the worker script, it won't fire properly. This results in no error on...

Yeah, I had a feeling the headers were ok, as thats pretty well documented in your tests. Applying this was less clear: ``` Map args = new HashMap(); args.put("x-delayed-type", "direct");...

I'm not seeing how `exchangeOptions` is leveraged here: https://github.com/mateodelnorte/servicebus/blob/master/bus/rabbitmq/bus.js#L21 The `options` object is never added as a whole to `this` for future reference, nor is the `exchangeOptions` prop directly referenced.

I tested it though and still did not get a delay applied: `const bus = servicebus.bus({url: rabbitmqUrl, exchangeOptions: {type: 'x-delayed-message'}});`

I found this gist on how to setup `ampqlib` appropriately to utilize the plugin: https://gist.github.com/mfressdorf/f46fdf266f35d8c525aea16719f837ac I'm not sure that servicebus will propagate all of these values to `ch.assertExchange`

Never mind. It looks like its addressed here: https://github.com/mateodelnorte/servicebus/blob/cb0729f1b9ba5a64fda0a4846a2b8e29275a6b3b/bus/rabbitmq/pubsubqueue.js#L45 As long as `exchangeOptions` is available it should work. This leads me back to my origin concern of: https://github.com/mateodelnorte/servicebus/issues/102#issuecomment-314528720

This PR ensures that the exchangeOptions and exchangeName are applied when the channel is setup: https://github.com/mateodelnorte/servicebus/pull/103 I still am having issues getting the delay to work properly, however. I have...

For those using Turborepo/Yarn Workspaces, this problem can manifest if `@ui-kitten` isn't added to the `nohoist` array in your root `package.json`. ``` ... "workspaces": { "packages": [ "apps/*", "packages/*" ],...

It looks like journey has updated their code. Just resourcer now.