Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Bower components Debian packages RPM packages NuGet packages

sentry / @nestjs/microservices   js

Repository URL to install this package:

Version: 7.0.10 

/ ctx-host / kafka.context.d.ts

import { KafkaMessage } from '../external/kafka.interface';
import { BaseRpcContext } from './base-rpc.context';
declare type KafkaContextArgs = [KafkaMessage, number, string];
export declare class KafkaContext extends BaseRpcContext<KafkaContextArgs> {
    constructor(args: KafkaContextArgs);
    /**
     * Returns the reference to the original message.
     */
    getMessage(): KafkaMessage;
    /**
     * Returns the partition.
     */
    getPartition(): number;
    /**
     * Returns the name of the topic.
     */
    getTopic(): string;
}
export {};