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 pipeline concept to RPC facility, fix javelin build issue

Browse Source
This commit is contained in:
Kelven Yang 2012-11-15 16:15:24 -08:00
parent 28b682c8db
commit 7a3ffb47e6
2 changed files with 9 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
framework/ipc/src/org/apache/cloudstack/framework/messaging/RpcCallContext.java
View File

@ -24,6 +24,7 @@ public class RpcCallContext {
Map<String, Object> _contextMap = new HashMap<String, Object>(); Map<String, Object> _contextMap = new HashMap<String, Object>();
int _timeoutMilliSeconds = DEFAULT_RPC_TIMEOUT; int _timeoutMilliSeconds = DEFAULT_RPC_TIMEOUT;
String _pipeline;
public RpcCallContext() { public RpcCallContext() {
} }
@ -36,6 +37,14 @@ public class RpcCallContext {
_timeoutMilliSeconds = timeoutMilliseconds; _timeoutMilliSeconds = timeoutMilliseconds;
} }
public void setPipeline(String pipeName) {
_pipeline = pipeName;
}
public String getPipeline() {
return _pipeline;
}
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public <T> T getContextParameter(String key) { public <T> T getContextParameter(String key) {
return (T)_contextMap.get(key); return (T)_contextMap.get(key);

24
server/src/com/cloud/cluster/ClusterEventBus.java
View File

@ -1,24 +0,0 @@
package com.cloud.cluster;
import java.io.Serializable;
import javax.annotation.PostConstruct;
import org.apache.cloudstack.framework.messaging.EventBusBase;
import org.apache.cloudstack.framework.messaging.PublishScope;
import org.springframework.stereotype.Component;
@Component
public class ClusterEventBus extends EventBusBase {
@PostConstruct
public void init() {
}
@Override
public void publish(String subject, PublishScope scope, Object sender,
Serializable args) {
super.publish(subject, scope, sender, args);
}
}