@effect-messaging/core@0.2.42

Patch Changes

• #140 89a7459 Thanks @adam-hotait! - Fix event handler being interrupted directly on SIGINT when handlerTimeout is set. Effect.timeoutFail relies on interruption internally, which does not work inside Effect.uninterruptible. The fix uses a Fiber-based race instead: the app is forked in an interruptible region so the timeout can interrupt it.

@effect-messaging/amqp@0.6.4

Patch Changes

• #138 6c3e80a Thanks @adam-hotait! - Add connectionTimeout option to AMQPConnectionOptions for configuring TCP socket and AMQP handshake timeout (defaults to 10 seconds)

@effect-messaging/nats@0.7.5

Patch Changes

• #135 3b033ee Thanks @wewelll! - Make JetStreamSubscriber and NATSSubscriber handlers always uninterruptible, and fix handlerTimeout.

  • Remove the uninterruptible option from JetStreamSubscriberOptions and NATSSubscriberOptions. Handlers are now always uninterruptible, ensuring in-flight message processing completes even when the subscription fiber is interrupted (e.g. SIGINT).
  • Fix handlerTimeout not working: the timeout previously couldn't fire because Effect.uninterruptible prevented the internal interrupt. Fixed by wrapping the handler in Effect.interruptible before timeoutFail, allowing the timeout to interrupt while the outer Effect.uninterruptible still blocks external interrupts.

@effect-messaging/amqp@0.6.3

Patch Changes

• #135 bb7ad9d Thanks @wewelll! - Make AMQPSubscriber handlers always uninterruptible, fix handlerTimeout, and explicitly cancel AMQP consumers on scope finalization.

  • Remove the uninterruptible option from AMQPSubscriberOptions. Handlers are now always uninterruptible, ensuring in-flight message processing completes even when the subscription fiber is interrupted (e.g. SIGINT).
  • Fix handlerTimeout not working: the timeout previously couldn't fire because Effect.uninterruptible prevented the internal interrupt. Fixed by wrapping the handler in Effect.interruptible before timeoutFail, allowing the timeout to interrupt while the outer Effect.uninterruptible still blocks external interrupts.
  • Capture the consumerTag from channel.consume() and register a scope finalizer to call channel.cancel(consumerTag), ensuring explicit consumer cancellation during graceful shutdown instead of relying solely on channel close.

@effect-messaging/nats@0.7.4

Patch Changes

• #130 45f957e Thanks @wewelll! - Upgrade @effect/language-service to ^0.78.0

• Updated dependencies [45f957e]:

  • @effect-messaging/core@0.2.41

@effect-messaging/core@0.2.41

Patch Changes

• #130 45f957e Thanks @wewelll! - Upgrade @effect/language-service to ^0.78.0

@effect-messaging/amqp@0.6.2

Patch Changes

• #130 45f957e Thanks @wewelll! - Upgrade @effect/language-service to ^0.78.0

• Updated dependencies [45f957e]:

  • @effect-messaging/core@0.2.41

@effect-messaging/nats@0.7.3

Patch Changes

• #128 462a8d4 Thanks @wewelll! - Upgrade dependencies:

  • effect to 3.19.19
  • @effect/platform to 0.94.5
  • @effect/language-service to 0.77.0
  • @nats-io/jetstream, @nats-io/nats-core, @nats-io/transport-node to 3.3.1
  • glob to 13.0.6
  • @changesets/changelog-github to 0.5.2
  • @changesets/cli to 2.29.8
  • typescript to 5.9.3
  • typescript-eslint to 8.56.1

• Updated dependencies [462a8d4]:

  • @effect-messaging/core@0.2.40

@effect-messaging/core@0.2.40

Patch Changes

• #128 462a8d4 Thanks @wewelll! - Upgrade dependencies:

  • effect to 3.19.19
  • @effect/platform to 0.94.5
  • @effect/language-service to 0.77.0
  • @nats-io/jetstream, @nats-io/nats-core, @nats-io/transport-node to 3.3.1
  • glob to 13.0.6
  • @changesets/changelog-github to 0.5.2
  • @changesets/cli to 2.29.8
  • typescript to 5.9.3
  • typescript-eslint to 8.56.1

@effect-messaging/amqp@0.6.1

Patch Changes

• #128 462a8d4 Thanks @wewelll! - Upgrade dependencies:

  • effect to 3.19.19
  • @effect/platform to 0.94.5
  • @effect/language-service to 0.77.0
  • @nats-io/jetstream, @nats-io/nats-core, @nats-io/transport-node to 3.3.1
  • glob to 13.0.6
  • @changesets/changelog-github to 0.5.2
  • @changesets/cli to 2.29.8
  • typescript to 5.9.3
  • typescript-eslint to 8.56.1

• Updated dependencies [462a8d4]:

  • @effect-messaging/core@0.2.40