Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
web services and bug fixes for distributed java systems (#1064)
* Inheritence bug fixed * Web services work partially * May29 some bug fixes * WS does not send the object type fixes for the inheritence in web serives and config file * fixes for the inheritence in web serives and config file * june13 fix for pattern 1 default component * Many bugs fixed for inheritence,web service marshalling and unmarshalling and more tests * fixed some issues
- Loading branch information
Showing
106 changed files
with
14,844 additions
and
630 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
138 changes: 138 additions & 0 deletions
138
UmpleToJava/UmpleTLTemplates/JavaDistributedTemplates.ump
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,138 @@ | ||
| use UmpleNotice.ump; | ||
| external interface ILang{} | ||
|
|
||
| class JavaDistributedTemplates { | ||
| depend cruise.umple.compiler.*; | ||
| depend cruise.umple.util.*; | ||
| depend java.util.*; | ||
| depend cruise.umple.parser.Position; | ||
|
|
||
| // Add a newline to the end of the input | ||
| private void appendln(StringBuilder buffer, String input, Object... variables) | ||
| { | ||
| append(buffer, input + "\n", variables); | ||
| } | ||
|
|
||
| // This method will be used to append formatted strings | ||
| // i.e. format("Hello {0} {1}", "andrew","forward"); | ||
| private void append(StringBuilder buffer, String input, Object... variables) | ||
| { | ||
| buffer.append(StringFormatter.format(input,variables)); | ||
| } | ||
|
|
||
| emit getproxyReadObjectCode(String remoteName, String packageName,String interfaceName,UmpleClass uClass)(ProxyreadObjectCode); | ||
|
|
||
| ProxyreadObjectCode <<! | ||
| <<#if (uClass.getExtendsClass() == null||(uClass.getExtendsClass() != null && ! uClass.getExtendsClass().getIsDistributed())) | ||
| { | ||
| #>> | ||
|
|
||
| public String remoteUrl; | ||
| public String objectId; | ||
| public String remotePort; | ||
| <<#}#>> | ||
| private static <<=remoteName>> umplenewInstance() | ||
| { | ||
| return new <<=remoteName>>((UmpleRuntime.UmpleNode)null); | ||
| } | ||
|
|
||
| protected <<=remoteName>> (UmpleRuntime.UmpleNode node) | ||
| { | ||
| <<# | ||
| if ((uClass.getExtendsClass() != null)&&(uClass.getExtendsClass().getIsDistributed())) | ||
| { | ||
| #>> | ||
| super(node); | ||
| <<# | ||
| } | ||
| else if ((uClass.getExtendsClass() != null)&& !(uClass.getExtendsClass().getIsDistributed())) | ||
| { | ||
| appendln(realSb,"super();"); | ||
| } | ||
| #>> | ||
| } | ||
|
|
||
| public void setRealObject(<<=interfaceName>> aObject) | ||
| { | ||
| <<# | ||
| if (uClass.getExtendsClass() != null && uClass.getExtendsClass().getIsDistributed()) | ||
| { | ||
| #>> | ||
| super.setRealObject(aObject); | ||
| <<# | ||
| } | ||
| #>> | ||
| realObject=aObject; | ||
| } | ||
| void afterUnmarshal(Unmarshaller u, Object parent) | ||
| { | ||
| initializeConnection(); | ||
| } | ||
| private void initializeConnection() | ||
| { | ||
| if(objectId.contains(<<=uClass.getName()>>.class.getName())) | ||
| { | ||
| boolean success = false; | ||
| while (!success) { | ||
| try | ||
| { | ||
| URL url = new URL(remoteUrl+":"+remotePort+"/<<=remoteName>>"+objectId+"?wsdl"); | ||
| QName qname = new QName("http://<<=packageName>>/","<<=remoteName>>Service"); | ||
| Service service = Service.create(url, qname); | ||
| setRealObject(service.getPort(<<=interfaceName>>.class)); | ||
| success = true; | ||
| } | ||
| catch (Exception e) | ||
| { | ||
| System.err.println("Client exception: " + e.toString()); | ||
| e.printStackTrace(); | ||
| try { Thread.sleep(1000); } catch (InterruptedException interruptedException) {}; | ||
| } | ||
| } | ||
| } | ||
| } | ||
| !>> | ||
|
|
||
| emit getproxyReadObjectCodeRMI(String remoteName, String packageName,String interfaceName,UmpleClass uClass)(ProxyreadObjectCodeRMI); | ||
|
|
||
| ProxyreadObjectCodeRMI <<! | ||
| <<#if (uClass.getExtendsClass() == null||(uClass.getExtendsClass() != null && ! uClass.getExtendsClass().getIsDistributed())) | ||
| { | ||
| #>> | ||
| protected <<=interfaceName>> remoteObject; | ||
| <<#}#>> | ||
| public void setRemoteObject(<<=interfaceName>> aRemoteObject) | ||
| { | ||
| remoteObject=aRemoteObject; | ||
| } | ||
| public <<=interfaceName>> getRemoteObject() | ||
| { | ||
| return (<<=interfaceName>>)remoteObject; | ||
| } | ||
| private void readObject(java.io.ObjectInputStream in) throws Exception | ||
| { | ||
| try | ||
| { | ||
| in.defaultReadObject(); | ||
| realObject=(<<=interfaceName>>)remoteObject; | ||
| } | ||
| catch(Exception e) | ||
| { | ||
| throw e; | ||
| } | ||
|
|
||
| } | ||
| !>> | ||
|
|
||
| emit getremoteSingletonCode(String remoteName, String packageName,String interfaceName)(remoteSingleton); | ||
| remoteSingleton <<! | ||
| protected <<=remoteName>>() | ||
| { | ||
| } | ||
| public <<=remoteName>>(String url,String port,String objectId) | ||
| { | ||
| Endpoint.publish(url+":"+port+"/<<=remoteName>>"+objectId,this); | ||
| } | ||
|
|
||
| !>> | ||
| } |
Oops, something went wrong.