import org.collectionspace.services.OrganizationJAXBSchema;\r
import org.collectionspace.services.client.OrgAuthorityClient;\r
import org.collectionspace.services.client.OrgAuthorityClientUtils;\r
+import org.collectionspace.services.client.PayloadInputPart;\r
+import org.collectionspace.services.client.PoxPayloadIn;\r
+import org.collectionspace.services.client.PoxPayloadOut;\r
import org.collectionspace.services.client.test.ServiceRequestType;\r
import org.collectionspace.services.organization.OrgauthoritiesCommon;\r
import org.collectionspace.services.organization.OrgauthoritiesCommonList;\r
logger.info("Import: Create Item: \""+shortName+\r
"\" in orgAuthority: \"" + orgAuthorityRefName +"\"");\r
PoxPayloadOut multipart = \r
- OrgAuthorityClientUtils.createOrganizationInstance( vcsid, \r
- refName, orgInfo, client.getItemCommonPartName() );\r
+ OrgAuthorityClientUtils.createOrganizationInstance(refName, orgInfo, client.getItemCommonPartName() );\r
\r
ClientResponse<Response> res = client.createItem(vcsid, multipart);\r
\r
// Submit the request to the service and store the response.\r
OrgauthoritiesCommon orgAuthority = null;\r
try {\r
- ClientResponse<PoxPayloadIn> res = client.read(orgAuthId);\r
+ ClientResponse<String> res = client.read(orgAuthId);\r
int statusCode = res.getStatus();\r
if(!REQUEST_TYPE.isValidStatusCode(statusCode)) {\r
throw new RuntimeException("Could not read orgAuthority"\r
throw new RuntimeException("Unexpected Status when reading " +\r
"orgAuthority, Status:"+ statusCode);\r
}\r
- PoxPayloadIn input = (PoxPayloadIn) res.getEntity();\r
- orgAuthority = (OrgauthoritiesCommon) extractPart(input,\r
- client.getCommonPartName(), OrgauthoritiesCommon.class);\r
+ PoxPayloadIn input = new PoxPayloadIn(res.getEntity());\r
+ PayloadInputPart orgAuthorityPart = input.getPart(client.getCommonPartName());\r
+ orgAuthority = (OrgauthoritiesCommon) orgAuthorityPart.getBody();\r
} catch (Exception e) {\r
throw new RuntimeException("Could not read orgAuthority: ", e);\r
}\r
return sb.toString();\r
}\r
\r
- private Object extractPart(PoxPayloadIn input, String label,\r
- Class clazz) throws Exception {\r
- Object obj = null;\r
- for(InputPart part : input.getParts()){\r
- String partLabel = part.getHeaders().getFirst("label");\r
- if(label.equalsIgnoreCase(partLabel)){\r
- String partStr = part.getBodyAsString();\r
- if(logger.isDebugEnabled()){\r
- logger.debug("extracted part str=\n" + partStr);\r
- }\r
- obj = part.getBody(clazz, null);\r
- if(logger.isDebugEnabled()){\r
- logger.debug("extracted part obj=\n", obj, clazz);\r
- }\r
- break;\r
- }\r
- }\r
- return obj;\r
- }\r
+// private Object extractPart(PoxPayloadIn input, String label,\r
+// Class clazz) throws Exception {\r
+// Object obj = null;\r
+// for(PayloadInputPart part : input.getParts()){\r
+// String partLabel = part.getHeaders().getFirst("label");\r
+// if(label.equalsIgnoreCase(partLabel)){\r
+// String partStr = part.getBodyAsString();\r
+// if(logger.isDebugEnabled()){\r
+// logger.debug("extracted part str=\n" + partStr);\r
+// }\r
+// obj = part.getBody(clazz, null);\r
+// if(logger.isDebugEnabled()){\r
+// logger.debug("extracted part obj=\n", obj, clazz);\r
+// }\r
+// break;\r
+// }\r
+// }\r
+// return obj;\r
+// }\r
\r
public static void main(String[] args) {\r
\r