text: "use strict";
  Object.defineProperty(exports, "__esModule", { value: true });
  const base_rpc_context_1 = require("./base-rpc.context");
  class KafkaContext extends base_rpc_context_1.BaseRpcContext {
      constructor(args) {
          super(args);
      }
      /**
       * Returns the reference to the original message.
       */
      getMessage() {
          return this.args[0];
      }
      /**
       * Returns the partition.
       */
      getPartition() {
          return this.args[1];
      }
      /**
       * Returns the name of the topic.
       */
      getTopic() {
          return this.args[2];
      }
  }
  exports.KafkaContext = KafkaContext;
  