Skip to content

Commit b38d9b8

Browse files
kelvenykelveny
committed
CloudStack messaging refactoring skeleton
1 parent a06eb45 commit b38d9b8

15 files changed

Lines changed: 455 additions & 40 deletions

‎framework/events/.project‎

Lines changed: 0 additions & 17 deletions
This file was deleted.

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/ComponentEndpoint.java‎

Lines changed: 75 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,75 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public class ComponentEndpoint implements RpcEndpoint, TransportMultiplexier {
22+
23+
private TransportEndpoint transportEndpoint;
24+
private RpcProvider rpcProvider;
25+
26+
public ComponentEndpoint() {
27+
}
28+
29+
public TransportEndpoint getTransportEndpoint() {
30+
return transportEndpoint;
31+
}
32+
33+
public void setTransportEndpoint(TransportEndpoint transportEndpoint) {
34+
this.transportEndpoint = transportEndpoint;
35+
}
36+
37+
public RpcProvider getRpcProvider() {
38+
return rpcProvider;
39+
}
40+
41+
public void setRpcProvider(RpcProvider rpcProvider) {
42+
this.rpcProvider = rpcProvider;
43+
}
44+
45+
public void initialize(String[] multiplexiers) {
46+
if(multiplexiers != null) {
47+
for(String name : multiplexiers)
48+
transportEndpoint.registerMultiplexier(name, this);
49+
}
50+
51+
rpcProvider.registerRpcEndpoint(this);
52+
}
53+
54+
@Override
55+
public void onTransportMessage(String senderEndpointAddress,
56+
String targetEndpointAddress, String multiplexer, String message) {
57+
}
58+
59+
@Override
60+
public String call(String targetAddress, String rpcMessage) {
61+
// TODO Auto-generated method stub
62+
return null;
63+
}
64+
65+
@Override
66+
public void asyncCall(String targetAddress, String rpcMessage) {
67+
// TODO Auto-generated method stub
68+
}
69+
70+
@Override
71+
public void onCall(RpcCall call) {
72+
// TODO Auto-generated method stub
73+
74+
}
75+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/RpcCall.java‎

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public interface RpcCall {
22+
String getCommand();
23+
String getContent();
24+
String getRequestTag();
25+
26+
void completeCall(String rpcMessage);
27+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/RpcCallHandler.java‎

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
import java.lang.annotation.ElementType;
22+
import java.lang.annotation.Retention;
23+
import java.lang.annotation.RetentionPolicy;
24+
import java.lang.annotation.Target;
25+
26+
@Retention(RetentionPolicy.RUNTIME)
27+
@Target(ElementType.METHOD)
28+
public @interface RpcCallHandler {
29+
String command();
30+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/RpcEndpoint.java‎

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public interface RpcEndpoint {
22+
public String call(String targetAddress, String rpcMessage);
23+
public void asyncCall(String targetAddress, String rpcMessage);
24+
25+
void onCall(RpcCall call);
26+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/RpcProvider.java‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public interface RpcProvider extends TransportMultiplexier {
22+
public void registerRpcEndpoint(RpcEndpoint rpcEndpoint);
23+
public void unregisteRpcEndpoint(RpcEndpoint rpcEndpoint);
24+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/TransportAddressFactory.java‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public interface TransportAddressFactory {
22+
String createServiceAddress(String serviceProvider);
23+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/TransportEndpoint.java‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public interface TransportEndpoint {
22+
void onAttachConfirm(String endpointAddress);
23+
24+
void registerMultiplexier(String name, TransportMultiplexier multiplexier);
25+
void unregisterMultiplexier(String name);
26+
27+
void sendMessage(TransportEndpoint sender, String targetEndpointAddress,
28+
String multiplexier, String message);
29+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/TransportMultiplexier.java‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public interface TransportMultiplexier {
22+
public void onTransportMessage(String senderEndpointAddress, String targetEndpointAddress,
23+
String multiplexer, String message);
24+
}

‎framework/ipc/src/org/apache/cloudstack/framework/messaging/TransportProvider.java‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
package org.apache.cloudstack.framework.messaging;
20+
21+
public interface TransportProvider {
22+
void attach(TransportEndpoint endpoint, String predefinedAddress);
23+
void detach(TransportEndpoint endpoint);
24+
}

0 commit comments

Comments
 (0)