lib/protobuf/nats.rb in protobuf-nats-0.3.0 vs lib/protobuf/nats.rb in protobuf-nats-0.3.1

@@ -43,10 +43,12 @@
     config
 
     def self.subscription_key(service_klass, service_method)
       service_class_name = service_klass.name.underscore.gsub("/", ".")
       service_method_name = service_method.to_s.underscore
-      "rpc.#{service_class_name}.#{service_method_name}"
+
+      subscription_key = "rpc.#{service_class_name}.#{service_method_name}"
+      subscription_key = config.make_subscription_key_replacements(subscription_key)
     end
 
     def self.start_client_nats_connection
       @start_client_nats_connection ||= begin
         GET_CONNECTED_MUTEX.synchronize do