Skip to main content

JetstreamConnection()

@horizon-republic/nestjs-jetstream

@horizon-republic/nestjs-jetstream / JetstreamConnection

JetstreamConnection()

JetstreamConnection(name): ClassDecorator

Defined in: src/server/connection.decorator.ts:31

Bind every @EventPattern / @MessagePattern handler on a controller to a named connection.

Method-level { connection } extras win over the class decorator. Method decorators run before class decorators, so pattern metadata is already in place by the time this runs.

Handlers inherited from a base controller are tagged too. Metadata lives on the function itself, so if two decorated subclasses extend the same base, the base's handlers keep the binding of whichever subclass was decorated first. Declare the pattern on the subclass when two clusters must share a base.

Parameters​

name​

string

Connection name as declared in forRoot({ connections }).

Returns​

ClassDecorator

Example​

@JetstreamConnection('analytics')
@Controller()
export class AnalyticsController {
  @EventPattern('page.viewed')
  handleView(@Payload() data: PageView) {}
}