提交 73e0071a 编写于 作者: Y yukon

Interface polish, remove unused exeption code

上级 6593294f
...@@ -17,19 +17,19 @@ ...@@ -17,19 +17,19 @@
package org.apache.rocketmq.rpc.api; package org.apache.rocketmq.rpc.api;
public interface AdvancedClient { public interface AdvancedClient {
<T> T callSync(String address, <T> T callSync(final String address,
final String serviceCode, final String serviceCode,
final String version, final String version,
final Object[] parameter, final Object[] parameter,
final Class<T> responseType) throws Exception; final Class<T> responseType) throws Exception;
<T> Promise<T> callAsync(String address, <T> Promise<T> callAsync(final String address,
final String serviceCode, final String serviceCode,
final String version, final String version,
final Object[] parameter, final Object[] parameter,
final Class<T> responseType) throws Exception; final Class<T> responseType) throws Exception;
void callOneway(String address, void callOneway(final String address,
final String serviceCode, final String serviceCode,
final String version, final String version,
final Object[] parameter) throws Exception; final Object[] parameter) throws Exception;
......
...@@ -22,11 +22,11 @@ import java.util.concurrent.ExecutorService; ...@@ -22,11 +22,11 @@ import java.util.concurrent.ExecutorService;
import org.apache.rocketmq.remoting.api.ObjectLifecycle; import org.apache.rocketmq.remoting.api.ObjectLifecycle;
public interface SimpleClient extends ObjectLifecycle { public interface SimpleClient extends ObjectLifecycle {
<T> T bind(Class<T> service, String address, Properties properties); //keyValue <T> T bind(final Class<T> service, final String address, final Properties properties);
void publish(Object service); void publish(final Object service);
void publish(Object service, ExecutorService executorService); void publish(final Object service, final ExecutorService executorService);
AdvancedClient advancedClient(); AdvancedClient advancedClient();
} }
...@@ -25,9 +25,9 @@ import org.apache.rocketmq.remoting.api.channel.RemotingChannel; ...@@ -25,9 +25,9 @@ import org.apache.rocketmq.remoting.api.channel.RemotingChannel;
public interface SimpleServer extends ObjectLifecycle { public interface SimpleServer extends ObjectLifecycle {
<T> T bind(final Class<T> service, final RemotingChannel channel, final Properties properties); <T> T bind(final Class<T> service, final RemotingChannel channel, final Properties properties);
AdvancedServer advancedServer();
void publish(final Object service); void publish(final Object service);
void publish(Object service, ExecutorService executorService); void publish(final Object service, final ExecutorService executorService);
AdvancedServer advancedServer();
} }
...@@ -41,26 +41,8 @@ public class ResponseCode { ...@@ -41,26 +41,8 @@ public class ResponseCode {
public static final String USER_EXCEPTION_CLASS_NOT_FOUND = "401"; public static final String USER_EXCEPTION_CLASS_NOT_FOUND = "401";
public static final String USER_EXCEPTION_METHOD_NOT_FOUND = "402"; public static final String USER_EXCEPTION_METHOD_NOT_FOUND = "402";
public static final String PROVIDER_OFF_LINE = "501";
public static final String CONSUMER_OFF_LINE = "502";
public static final String PROVIDER_NOT_EXIST = "503";
public static final String CONSUMER_NOT_EXIST = "504";
public static final String NAMESPACE_NOT_EXIST = "505";
public static final String CLIENT_NOT_REGISTERED = "506";
public static final String NO_SERVICE_ON_LINE = "507";
public static final String NO_SERVICE_ON_THIS_SERVER = "508";
public static final String SERVICE_ALREADY_ONLINE = "509";
public static final String SERVER_NOT_EXIST = "510";
public static final String SERVER_ALREADY_ONLINE = "511";
public static final String NO_SERVER_ON_LINE = "512";
public static final String ACCESS_DENIED = "513";
public static final String SYSTEM_ERROR = "600";
public static final String SYSTEM_BUSY = "601";
public static final String BAD_REQUEST = "602";
public static final String PARAMETER_ERROR = "603"; public static final String PARAMETER_ERROR = "603";
public static final String SEND_REQUEST_FAILED = "604";
public static final String REQUEST_TIMEOUT = "605";
public static final String UNKNOWN_EXCEPTION = "606"; public static final String UNKNOWN_EXCEPTION = "606";
@Override @Override
...@@ -78,25 +60,8 @@ public class ResponseCode { ...@@ -78,25 +60,8 @@ public class ResponseCode {
R_400(400, "User service happened"), R_400(400, "User service happened"),
R_401(401, "Class not found"), R_401(401, "Class not found"),
R_402(402, "Method not found"), R_402(402, "Method not found"),
R_501(501, "Service provider offline "),
R_502(502, "Service consumer offline"),
R_503(503, "Service provider not exist"),
R_504(504, "Service consumer not exist"),
R_505(505, "Namespace not exist"),
R_506(506, "Client not registered"),
R_507(507, "No service online"),
R_508(508, "No service on this server"),
R_509(509, "Server already online"),
R_510(510, "Server not exist"),
R_511(511, "Server already online"),
R_512(512, "No server online"),
R_513(513, "Access denied"),
R_600(600, "System error"),
R_601(601, "System busy"),
R_602(602, "Bad request"),
R_603(603, "Parameter error"), R_603(603, "Parameter error"),
R_604(604, "Send request failed"),
R_605(605, "Request timeout"),
R_606(606, "unknown exception"); R_606(606, "unknown exception");
private int responseCode = 0; private int responseCode = 0;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册