apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-10-26 08:42:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

add anonymouse client RPC endpoint support

Browse Source
This commit is contained in:
Kelven Yang 2012-12-03 16:29:14 -08:00
parent 28db7981b9
commit d836b14a64
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
framework/ipc/src/org/apache/cloudstack/framework/messaging/RpcProvider.java
View File

@ -27,7 +27,9 @@ public interface RpcProvider extends TransportMultiplexier {
void registerRpcServiceEndpoint(RpcServiceEndpoint rpcEndpoint); void registerRpcServiceEndpoint(RpcServiceEndpoint rpcEndpoint);
void unregisteRpcServiceEndpoint(RpcServiceEndpoint rpcEndpoint); void unregisteRpcServiceEndpoint(RpcServiceEndpoint rpcEndpoint);
RpcClientCall newCall(String sourceAddress, String targetAddress); RpcClientCall newCall(TransportEndpoint sourceEndpoint, String targetAddress);
RpcClientCall newCall(String targetAddress);
void registerCall(RpcClientCall call); void registerCall(RpcClientCall call);
void cancelCall(RpcClientCall call); void cancelCall(RpcClientCall call);

11
framework/ipc/src/org/apache/cloudstack/framework/messaging/RpcProviderImpl.java
View File

@ -83,16 +83,23 @@ public class RpcProviderImpl implements RpcProvider {
} }
@Override @Override
public RpcClientCall newCall(String sourceAddress, String targetAddress) { public RpcClientCall newCall(TransportEndpoint sourceEndpoint, String targetAddress) {
long callTag = getNextCallTag(); long callTag = getNextCallTag();
RpcClientCallImpl call = new RpcClientCallImpl(this); RpcClientCallImpl call = new RpcClientCallImpl(this);
call.setSourceAddress(sourceAddress); call.setSourceAddress(sourceEndpoint.getEndpointAddress());
call.setTargetAddress(targetAddress); call.setTargetAddress(targetAddress);
call.setCallTag(callTag); call.setCallTag(callTag);
return call; return call;
} }
@Override
public RpcClientCall newCall(String targetAddress) {
// ???
return null;
}
@Override @Override
public void registerCall(RpcClientCall call) { public void registerCall(RpcClientCall call) {
assert(call != null); assert(call != null);