[jboss-svn-commits] JBL Code SVN: r15651 - in labs/jbossesb/trunk/product/rosetta: tests/src/org/jboss/internal/soa/esb/services/registry and 1 other directory.

[jboss-svn-commits at lists.jboss.org]

Author: kurt.stam at jboss.com
Date: 2007-10-08 11:36:15 -0400 (Mon, 08 Oct 2007)
New Revision: 15651

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryImpl.java
   labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryUnitTest.java
Log:
JBESB-1137, rolling back for now.

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryImpl.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryImpl.java	2007-10-08 14:59:47 UTC (rev 15650)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryImpl.java	2007-10-08 15:36:15 UTC (rev 15651)
@@ -23,6 +23,8 @@
 
 import java.io.UnsupportedEncodingException;
 import java.net.PasswordAuthentication;
+import java.net.URLDecoder;
+import java.net.URLEncoder;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashSet;
@@ -199,7 +201,7 @@
 			ServiceBinding serviceBinding = blm.createServiceBinding();
 			serviceBinding.setDescription(blm.createInternationalString(eprDescription));
 			String xml = EPRHelper.toXMLString(epr);
-			serviceBinding.setAccessURI(xml);
+			serviceBinding.setAccessURI(URLEncoder.encode(xml,"UTF-8"));
 		
 		    ArrayList<ServiceBinding> serviceBindings = new ArrayList<ServiceBinding>();
 		    serviceBindings.add(serviceBinding);
@@ -214,6 +216,8 @@
 			saveRegistryObject(serviceBinding);
 		} catch (JAXRException je) {
 			throw new RegistryException(je.getLocalizedMessage(), je);
+        } catch (UnsupportedEncodingException uee) {
+            throw new RegistryException(uee.getLocalizedMessage(), uee);
         } catch (MarshalException me) {
             throw new RegistryException(me.getLocalizedMessage(), me);
 		} finally {
@@ -238,7 +242,7 @@
 			service.addServiceBindings(serviceBindings);
 			for (Iterator i=serviceBindings.iterator();i.hasNext();){
 				ServiceBinding serviceBinding = (ServiceBinding) i.next();
-				String xml = serviceBinding.getAccessURI();
+				String xml = URLDecoder.decode(serviceBinding.getAccessURI(), "UTF-8");
 				if (xml.equals(EPRHelper.toXMLString(toBeDeletedEPR))) {
                     RegistryService rs = connection.getRegistryService();
                     BusinessLifeCycleManager blm = rs.getBusinessLifeCycleManager();
@@ -252,6 +256,8 @@
                     + serviceName + " and EPR=" + toBeDeletedEPR);
 		} catch (JAXRException je) {
 			throw new RegistryException(je.getLocalizedMessage(), je);
+        } catch (UnsupportedEncodingException uee) {
+            throw new RegistryException(uee.getLocalizedMessage(), uee);
         } catch (MarshalException me) {
             throw new RegistryException(me.getLocalizedMessage(), me);
 		} finally {
@@ -317,12 +323,14 @@
 			for (Iterator i=serviceBindings.iterator();i.hasNext();) {
 				ServiceBinding serviceBinding = (ServiceBinding) i.next();
 				@SuppressWarnings("unused")
-				String eprXML = serviceBinding.getAccessURI();
+				String eprXML = URLDecoder.decode(serviceBinding.getAccessURI(),"UTF-8");
 				EPR epr = EPRHelper.fromXMLString(eprXML);
 				eprs.add(epr);
 			}
 		} catch (JAXRException je) {
 			throw new RegistryException(je.getLocalizedMessage(), je);
+        } catch (UnsupportedEncodingException uee) {
+            throw new RegistryException(uee.getLocalizedMessage(), uee);
         } catch (UnmarshalException me) {
             throw new RegistryException(me.getLocalizedMessage(), me);
 		} finally {
@@ -348,11 +356,13 @@
 			Collection<ServiceBinding> serviceBindings = findServiceBindings(service);
 			if (serviceBindings.iterator().hasNext()) {
 				ServiceBinding serviceBinding = (ServiceBinding) serviceBindings.iterator().next();
-				String eprXML = serviceBinding.getAccessURI();
+				String eprXML = URLDecoder.decode(serviceBinding.getAccessURI(),"UTF-8");
 				epr = EPRHelper.fromXMLString(eprXML);
 			}
 		} catch (JAXRException je) {
 			throw new RegistryException(je.getLocalizedMessage(), je);
+        } catch (UnsupportedEncodingException uee) {
+            throw new RegistryException(uee.getLocalizedMessage(), uee);
         } catch (UnmarshalException me) {
             throw new RegistryException(me.getLocalizedMessage(), me);
 		} finally {

Modified: labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryUnitTest.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryUnitTest.java	2007-10-08 14:59:47 UTC (rev 15650)
+++ labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/internal/soa/esb/services/registry/JAXRRegistryUnitTest.java	2007-10-08 15:36:15 UTC (rev 15651)
@@ -26,6 +26,7 @@
 
 import java.io.File;
 import java.io.InputStream;
+import java.net.URLDecoder;
 import java.sql.DriverManager;
 import java.sql.Statement;
 import java.util.ArrayList;
@@ -169,7 +170,7 @@
 				for (Iterator serviceBindingIter = serviceBindings.iterator();serviceBindingIter.hasNext();){
 					ServiceBinding serviceBinding = (ServiceBinding) serviceBindingIter.next();
 					logger.debug("  ServiceBinding Description: " + serviceBinding.getDescription().getValue());
-					String xml = serviceBinding.getAccessURI();
+					String xml = URLDecoder.decode(serviceBinding.getAccessURI(),"UTF-8");
 					logger.debug("  ServiceBinding URI: " + xml);
 					assertEquals(EPRHelper.toXMLString(new EPR()),xml);
 				}