Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 9001dd041e | |||
| 1bb26b4680 | |||
| a6d825ef9b | |||
| 6cc0334b9b | |||
| d6cb6e40a8 | |||
| fb10622960 | |||
| 2a9c36babb | |||
| bc4e506ea8 | |||
| 59089462e7 |
@@ -110,6 +110,7 @@ abstract class JsonRpcConsumers implements OnRpcConsumerInterface
|
||||
* @param $service
|
||||
* @return array
|
||||
* @throws RpcServiceException|\ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
private function get_consul($service): array
|
||||
{
|
||||
|
||||
+2
-3
@@ -47,9 +47,6 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
|
||||
public Note $annotation;
|
||||
|
||||
|
||||
#[Inject(EventProvider::class)]
|
||||
public EventProvider $eventProvider;
|
||||
|
||||
|
||||
private RpcManager $manager;
|
||||
|
||||
@@ -72,8 +69,10 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
|
||||
|
||||
/**
|
||||
* @param OnBeforeShutdown $beforeShutdown
|
||||
* @return void
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function onBeforeShutdown(OnBeforeShutdown $beforeShutdown)
|
||||
{
|
||||
|
||||
+1
-1
@@ -120,7 +120,7 @@ class RpcManager extends Component
|
||||
foreach ($this->_rpc as $list) {
|
||||
$data = $agent->service->register($list['config']);
|
||||
if ($data->getStatusCode() != 200) {
|
||||
exit($data->getBody());
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user