Skip to content
This repository was archived by the owner on May 12, 2021. It is now read-only.

Updates the pom with meta data service #39

Closed
swgkg wants to merge 2 commits into from
Closed

Updates the pom with meta data service #39

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
ecc7d98
updates the pom with meta data service
Sep 16, 2014
3463763
remove unnecssary logs
Sep 16, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion ...adataservice/src/main/java/org/apache/stratos/metadataservice/listener/TopologyAgent.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,8 +67,10 @@ protected void onEvent(Event event) {
log.debug("Member terminated event received");
}
MemberTerminatedEvent memberTerminatedEvent = (MemberTerminatedEvent) event;
System.out.println("Terminated event :::::::::::::::::::: " +
if(log.isDebugEnabled()){
log.debug("Terminated event :::::::::::::::::::: " +
memberTerminatedEvent.getServiceName());
}
new MetaDataAdmin().removeCartridgeMetaDataDetails("appA", "php");

} catch (Exception e) {
Expand Down
6 changes: 4 additions & 2 deletions ...taservice/src/main/java/org/apache/stratos/metadataservice/listener/TopologyListener.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,8 +59,10 @@ protected void onEvent(Event event) {
log.debug("Member terminated event received");
}
MemberTerminatedEvent memberTerminatedEvent = (MemberTerminatedEvent) event;
System.out.println("Terminated event :::::::::::::::::::: " +
memberTerminatedEvent.getServiceName());
if(log.isDebugEnabled()){
log.info("Terminated event :::::::::::::::::::: " +
memberTerminatedEvent.getServiceName());
}
new MetaDataAdmin().removeCartridgeMetaDataDetails("appA", "php");

// extensionHandler.onMemberTerminatedEvent(memberTerminatedEvent);
Expand Down
28 changes: 13 additions & 15 deletions ...dataservice/src/main/java/org/apache/stratos/metadataservice/registry/CarbonRegistry.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ public CarbonRegistry() {
@Override
public String addCartridgeMetaDataDetails(String applicationName, String cartridgeType,
CartridgeMetaData cartridgeMetaData) throws Exception {
System.out.println("Adding meta data details");


Registry tempRegistry = getGovernanceUserRegistry();
try {
Expand Down Expand Up @@ -96,24 +96,24 @@ public String addCartridgeMetaDataDetails(String applicationName, String cartrid

tempRegistry.put(resourcePath, resource);

System.out.println("A resource added to: " + resourcePath);

System.out.println(cartridgeMetaData.type);
// registry.rateResource(resourcePath, defaultRank);
if(log.isDebugEnabled()){
log.debug("A resource added to: " + resourcePath);
}


Comment comment = new Comment();
comment.setText("Added the " + applicationName + " " + type + " cartridge");
// registry.addComment(resourcePath, comment);

} catch (Exception e) {

System.out.println(e.getMessage());
e.printStackTrace();
if (log.isErrorEnabled()) {
log.error("addCartridgeMetaDataDetails", e);
}
} finally {
// Close the session

}
System.out.println("Add meta data details");

return "success";
}

Expand All @@ -134,10 +134,7 @@ public String getCartridgeMetaDataDetails(String applicationName, String cartrid
if (registry.resourceExists(resourcePath)) {

Resource getResource = registry.get(resourcePath);
System.out.println("Resource retrived");
System.out.println("Printing retrieved resource content: " +
new String((byte[]) getResource.getContent()));


cartridgeMetaData.type = getResource.getProperty("Cartidge Type");
cartridgeMetaData.applicationName = getResource.getProperty("Application Name");
cartridgeMetaData.description = getResource.getProperty("Description");
Expand All @@ -159,8 +156,9 @@ public String getCartridgeMetaDataDetails(String applicationName, String cartrid

} catch (Exception e) {

System.out.println(e.getMessage());
e.printStackTrace();
if (log.isErrorEnabled()) {
log.error("getCartridgeMetaDataDetails", e);
}
} finally {
// Close the session

Expand Down
26 changes: 14 additions & 12 deletions ...tadataservice/src/main/java/org/apache/stratos/metadataservice/registry/GRegRegistry.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ private static WSRegistryServiceClient setRegistry() throws Exception {
@Override
public String addCartridgeMetaDataDetails(String applicationName, String cartridgeType,
CartridgeMetaData cartridgeMetaData) throws Exception {
System.out.println("Adding meta data details");

Registry registry = setRegistry();
try {

Expand Down Expand Up @@ -129,9 +129,7 @@ public String addCartridgeMetaDataDetails(String applicationName, String cartrid

registry.put(resourcePath, resource);

System.out.println("A resource added to: " + resourcePath);

System.out.println(cartridgeMetaData.type);

registry.rateResource(resourcePath, defaultRank);

Comment comment = new Comment();
Expand All @@ -140,13 +138,14 @@ public String addCartridgeMetaDataDetails(String applicationName, String cartrid

} catch (Exception e) {

System.out.println(e.getMessage());
e.printStackTrace();
if (log.isErrorEnabled()) {
log.error("addCartridgeMetaDataDetails", e);
}
} finally {
// Close the session
((WSRegistryServiceClient) registry).logut();
}
System.out.println("Add meta data details");

return "success";
}

Expand All @@ -167,9 +166,11 @@ public String getCartridgeMetaDataDetails(String applicationName, String cartrid
if (registry.resourceExists(resourcePath)) {

Resource getResource = registry.get(resourcePath);
System.out.println("Resource retrived");
System.out.println("Printing retrieved resource content: " +
new String((byte[]) getResource.getContent()));
if(log.isDebugEnabled()){
log.debug("Resource retrived");
log.debug("Printing retrieved resource content: " +
new String((byte[]) getResource.getContent()));
}

cartridgeMetaData.type = getResource.getProperty("Cartidge Type");
cartridgeMetaData.applicationName = getResource.getProperty("Application Name");
Expand All @@ -192,8 +193,9 @@ public String getCartridgeMetaDataDetails(String applicationName, String cartrid

} catch (Exception e) {

System.out.println(e.getMessage());
e.printStackTrace();
if (log.isErrorEnabled()) {
log.error("getCartridgeMetaDataDetails", e);
}
} finally {
// Close the session
((WSRegistryServiceClient) registry).logut();
Expand Down
2 changes: 2 additions & 0 deletions components/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,8 @@
<module>org.apache.stratos.rest.endpoint</module>
<!-- Stratos manager styles bundle -->
<module>org.apache.stratos.manager.styles</module>

<module>org.apache.stratos.metadataservice</module>

</modules>

Expand Down
1 change: 1 addition & 0 deletions features/manager/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,7 @@
<module>logging-mgt</module>
<module>rest-endpoint/org.apache.stratos.rest.endpoint.feature</module>
<module>styles/org.apache.stratos.manager.styles.feature</module>
<module>metadataservice/org.apache.stratos.metadataservice.feature</module>
</modules>

<properties>
Expand Down