diff --git a/JsonRpcConsumers.php b/JsonRpcConsumers.php
index 2c89e56..a1d6d7e 100644
--- a/JsonRpcConsumers.php
+++ b/JsonRpcConsumers.php
@@ -21,138 +21,138 @@ abstract class JsonRpcConsumers implements OnRpcConsumerInterface
 {
 
 
-	/**
-	 * @var Pool
-	 */
-	public Pool $pool;
+    /**
+     * @var Pool
+     */
+    public Pool $pool;
 
 
-	/**
-	 * @var RpcManager
-	 */
-	#[Inject(RpcManager::class)]
-	public RpcManager $manager;
+    /**
+     * @var RpcManager
+     */
+    #[Inject(RpcManager::class)]
+    public RpcManager $manager;
 
 
-	/**
-	 * @var RpcClientInterface
-	 */
-	#[Inject(RpcClientInterface::class)]
-	public RpcClientInterface $client;
+    /**
+     * @var RpcClientInterface
+     */
+    #[Inject(RpcClientInterface::class)]
+    public RpcClientInterface $client;
 
 
-	protected string $name = '';
+    protected string $name = '';
 
 
-	/**
-	 * @param string $method
-	 * @param mixed $data
-	 * @param string $version
-	 * @throws Exception
-	 * @throws ClientExceptionInterface
-	 */
-	public function notify(string $method, mixed $data, string $version = '2.0'): void
-	{
-		$this->client->withConfig($this->get_consul($this->name))->sendRequest(
-			$this->requestBody([
-				'jsonrpc' => $version,
-				'service' => $this->name,
-				'method'  => $method,
-				'params'  => $data,
-			])
-		);
-	}
+    /**
+     * @param string $method
+     * @param mixed $data
+     * @param string $version
+     * @throws Exception
+     * @throws ClientExceptionInterface
+     */
+    public function notify(string $method, mixed $data, string $version = '2.0'): void
+    {
+        $this->client->withConfig($this->get_consul($this->name))->sendRequest(
+            $this->requestBody([
+                'jsonrpc' => $version,
+                'service' => str_starts_with($this->name, '/') ? $this->name : '/' . $this->name,
+                'method' => $method,
+                'params' => $data,
+            ])
+        );
+    }
 
 
-	/**
-	 * @param array $data
-	 * @return ServerRequestInterface
-	 */
-	private function requestBody(array $data): ServerRequestInterface
-	{
-		$server = Kiri::getDi()->get(ServerRequest::class);
-		return $server->withBody(new Stream(json_encode($data)));
-	}
+    /**
+     * @param array $data
+     * @return ServerRequestInterface
+     */
+    private function requestBody(array $data): ServerRequestInterface
+    {
+        $server = Kiri::getDi()->get(ServerRequest::class);
+        return $server->withBody(new Stream(json_encode($data)));
+    }
 
 
-	/**
-	 * @param string $method
-	 * @param mixed $data
-	 * @param string $version
-	 * @param string $id
-	 * @return mixed
-	 * @throws Exception
-	 * @throws ClientExceptionInterface
-	 */
-	public function get(string $method, mixed $data, string $version = '2.0', string $id = ''): ResponseInterface
-	{
-		if (empty($id)) $id = Number::create(time());
+    /**
+     * @param string $method
+     * @param mixed $data
+     * @param string $version
+     * @param string $id
+     * @return mixed
+     * @throws Exception
+     * @throws ClientExceptionInterface
+     */
+    public function get(string $method, mixed $data, string $version = '2.0', string $id = ''): ResponseInterface
+    {
+        if (empty($id)) $id = Number::create(time());
 
-		return $this->client->withConfig($this->get_consul($this->name))->sendRequest(
-			$this->requestBody([
-				'jsonrpc' => $version,
-				'service' => $this->name,
-				'method'  => $method,
-				'params'  => $data,
-				'id'      => $id
-			])
-		);
-	}
+        return $this->client->withConfig($this->get_consul($this->name))->sendRequest(
+            $this->requestBody([
+                'jsonrpc' => $version,
+                'service' => str_starts_with($this->name, '/') ? $this->name : '/' . $this->name,
+                'method' => $method,
+                'params' => $data,
+                'id' => $id
+            ])
+        );
+    }
 
 
-	/**
-	 * @param array $data
-	 * @return mixed
-	 * @throws ClientExceptionInterface
-	 * @throws Exception
-	 */
-	public function batch(array $data): mixed
-	{
-		return $this->client->withConfig($this->get_consul($this->name))->sendRequest(
-			$this->requestBody($data)
-		);
-	}
+    /**
+     * @param array $data
+     * @return mixed
+     * @throws ClientExceptionInterface
+     * @throws Exception
+     */
+    public function batch(array $data): mixed
+    {
+        return $this->client->withConfig($this->get_consul($this->name))->sendRequest(
+            $this->requestBody($data)
+        );
+    }
 
 
-	/**
-	 * @param $service
-	 * @return array
-	 * @throws RpcServiceException|\ReflectionException
-	 * @throws Exception
-	 */
-	private function get_consul($service): array
-	{
-		if (empty($service)) {
-			throw new RpcServiceException('You need set rpc service name if used.');
-		}
-		$sf = $this->manager->getServices($service);
-		if (empty($sf) || !is_array($sf)) {
-			throw new RpcServiceException('You need set rpc service name if used.');
-		}
-		return $this->_loadRand($sf);
-	}
+    /**
+     * @param $service
+     * @return array
+     * @throws RpcServiceException|\ReflectionException
+     * @throws Exception
+     */
+    private function get_consul($service): array
+    {
+        if (empty($service)) {
+            throw new RpcServiceException('You need set rpc service name if used.');
+        }
+        $sf = $this->manager->getServices($service);
+        if (empty($sf) || !is_array($sf)) {
+            throw new RpcServiceException('You need set rpc service name if used.');
+        }
+        return $this->_loadRand($sf);
+    }
 
 
-	/**
-	 * @param $services
-	 * @return array
-	 */
-	private function _loadRand($services): array
-	{
-		$array = [];
-		foreach ($services as $value) {
-			$value['Weight'] = $value['Weights']['Passing'];
-			$array[] = $value;
-		}
-		if (count($array) < 2) {
-			$luck = $array[0];
-		} else {
-			$luck = Luckdraw::luck($array, 'Weight');
-		}
-		return [
-			'Address' => $luck['TaggedAddresses']['wan_ipv4']['Address'],
-			'Port'    => $luck['TaggedAddresses']['wan_ipv4']['Port']
-		];
-	}
+    /**
+     * @param $services
+     * @return array
+     */
+    private function _loadRand($services): array
+    {
+        $array = [];
+        foreach ($services as $value) {
+            $value['Weight'] = $value['Weights']['Passing'];
+            $array[] = $value;
+        }
+        if (count($array) < 2) {
+            $luck = $array[0];
+        } else {
+            $luck = Luckdraw::luck($array, 'Weight');
+        }
+        return [
+            'Address' => $luck['TaggedAddresses']['wan_ipv4']['Address'],
+            'Port' => $luck['TaggedAddresses']['wan_ipv4']['Port']
+        ];
+    }
 
 }
diff --git a/RpcJsonp.php b/RpcJsonp.php
index 12046f7..5db71b3 100644
--- a/RpcJsonp.php
+++ b/RpcJsonp.php
@@ -226,9 +226,6 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
     private function dispatch($data): array
     {
         try {
-            if (!str_starts_with($data['service'], '/')) {
-                $data['service'] = '/' . $data['service'];
-            }
             $handler = $this->collector->find($data['service'], 'GET');
             if (is_integer($handler) || is_null($handler)) {
                 throw new Exception('Handler not found', -32601);