Let's assume you wants to import the candidates into Taleo systems. Using Taleo BulkAPI, CandidateService allows your application to create and update a candidate in Taleo systems.
We can implement the above usecase with following options:
- Java Code using SAAJ: SAAJ stands for "SOAP with Attachments API for Java." With it, you can make Java API calls that generate XML messages which comply with the SOAP 1.1 or 1.2 specifications, as well as the WS-I Basic Profile 1.1 specification. It allows developers to read and write SOAP-based XML messages, and in some cases, to send and receive those messages over the Internet. SAAJ offers an alternative to JAX-RPC or JAX-WS
public class SOAPClientSAAJ {
/**
* This method process the new candidate creation
* @return employeeNumber
* @throws SOAPException
* @throws Exception
*/
public static String processCandidateCreationSOAPRequest() throws SOAPException, Exception {
SOAPConnectionFactory soapConnectionFactory = SOAPConnectionFactory.newInstance();
SOAPConnection soapConnection = soapConnectionFactory.createConnection();
// Trust to certificates
doTrustToCertificates();
// Send SOAP Message to SOAP Server
String url = "https://xxx.taleo.net/enterprise/soap?ServiceName=CandidateService";
SOAPMessage soapResponse = soapConnection.call(callCandidateCreationSOAPRequest(), url);
String employeeNumber = processCandidateCreationSOAPResponse(soapResponse);
return employeeNumber;
}
public SOAPClientSAAJ() {
super();
}
/**
* This method parse the soapResponse and gets the employeeNumber
* @param soapResponse
* @return employeeNumber
* @throws TransformerConfigurationException
* @throws SOAPException
* @throws ParserConfigurationException
* @throws TransformerException
* @throws SAXException
* @throws IOException
*/
private static String processCandidateCreationSOAPResponse(SOAPMessage soapResponse) throws TransformerConfigurationException,
SOAPException,
ParserConfigurationException,
TransformerException, SAXException,
IOException {
TransformerFactory transformerFactory = TransformerFactory.newInstance();
Transformer transformer = transformerFactory.newTransformer();
Source sourceContent = soapResponse.getSOAPPart().getContent();
StringWriter writer = new StringWriter();
transformer.transform(sourceContent, new StreamResult(writer));
String output = writer.toString();
DocumentBuilder db = DocumentBuilderFactory.newInstance().newDocumentBuilder();
InputSource is = new InputSource();
is.setCharacterStream(new StringReader(output));
Document doc = db.parse(is);
NodeList nodes = doc.getElementsByTagName("createResponse");
Element element = (Element)nodes.item(0);
NodeList name = element.getElementsByTagName("Number");
Element line = (Element)name.item(0);
return getCharacterDataFromElement(line).toString();
}
/**
* This method creates the soapMessage and calls the webservice
* @return
* @throws Exception
*/
private static SOAPMessage callCandidateCreationSOAPRequest() throws Exception {
MessageFactory messageFactory = MessageFactory.newInstance();
SOAPMessage soapMessage = messageFactory.createMessage();
SOAPPart soapPart = soapMessage.getSOAPPart();
// SOAP Envelope
SOAPEnvelope envelope = soapPart.getEnvelope();
envelope.addNamespaceDeclaration("can", "http://www.taleo.com/ws/tee800/2009/01/candidate");
envelope.addNamespaceDeclaration("ns1",
"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd");
SOAPHeader soapHeader = envelope.getHeader();
SOAPElement SecuritySoapElement = soapHeader.addChildElement("Security", "ns1");
SOAPElement usernameTokenSoapElement = SecuritySoapElement.addChildElement("UsernameToken", "ns1");
SOAPElement usernameSoapElement = usernameTokenSoapElement.addChildElement("Username", "ns1");
usernameSoapElement.addTextNode("username");
SOAPElement passwordSoapElement = usernameTokenSoapElement.addChildElement("Password", "ns1");
passwordSoapElement.addTextNode("password");
// SOAP Body
SOAPBody soapBody = envelope.getBody();
SOAPElement createSoapBodyElem = soapBody.addChildElement("create", "can");
SOAPElement candidateSoapBodyElem = createSoapBodyElem.addChildElement("candidate", "can");
SOAPElement emailAddressSoapBodyElem = candidateSoapBodyElem.addChildElement("EmailAddress", "can");
emailAddressSoapBodyElem.addTextNode("xxx@invalid.address.com");
SOAPElement addressSoapBodyElem = candidateSoapBodyElem.addChildElement("Address", "can");
addressSoapBodyElem.addTextNode("123 Main Street");
SOAPElement address2SoapBodyElem = candidateSoapBodyElem.addChildElement("Address2", "can");
address2SoapBodyElem.addTextNode("Apartment 1");
SOAPElement firstNameSoapBodyElem = candidateSoapBodyElem.addChildElement("FirstName", "can");
firstNameSoapBodyElem.addTextNode("XYZ");
SOAPElement lastNameSoapBodyElem = candidateSoapBodyElem.addChildElement("LastName", "can");
lastNameSoapBodyElem.addTextNode("XYZ");
// Save message
soapMessage.saveChanges();
return soapMessage;
}
/**
* This method trust the https certificates
* @throws Exception
*/
private static void doTrustToCertificates() throws Exception {
Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider());
TrustManager[] trustAllCerts = new TrustManager[] { new X509TrustManager() {
public X509Certificate[] getAcceptedIssuers() {
return null;
}
public void checkServerTrusted(X509Certificate[] certs, String authType) throws CertificateException {
return;
}
public void checkClientTrusted(X509Certificate[] certs, String authType) throws CertificateException {
return;
}
} };
SSLContext sc = SSLContext.getInstance("SSL");
sc.init(null, trustAllCerts, new SecureRandom());
HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
HostnameVerifier hv = new HostnameVerifier() {
public boolean verify(String urlHostName, SSLSession session) {
if (!urlHostName.equalsIgnoreCase(session.getPeerHost())) {
System.out.println("Warning: URL host '" + urlHostName + "' is different to SSLSession host '" +
session.getPeerHost() + "'.");
}
return true;
}
};
HttpsURLConnection.setDefaultHostnameVerifier(hv);
}
private static String getCharacterDataFromElement(Element e) {
Node child = e.getFirstChild();
if (child instanceof CharacterData) {
CharacterData cd = (CharacterData)child;
return cd.getData();
}
return "";
}
}
- Java Code using Apache Axis2: - First you should Import the WSDL Files into Your Development Platform using below command.
“wsdl2java.bat -uri pathToWsdl/WsdlFilename -d xmlbeans -ns2p namespaceURL=javaPackageName”
public class CandidateDC {
/**
* Main method call the importCandidate method
* @param args
*/
public static void main(String[] args) {
try {
long employeeNumber = importCandidate();
System.out.println("Candidate Num: " + employeeNumber);
} catch (AxisFault e) {
e.printStackTrace();
} catch (RemoteException e) {
e.printStackTrace();
} catch (WebServiceFault e) {
e.printStackTrace();
}
}
/**
* This method process the new candidate creation
* @return employeeNumber
* @throws AxisFault
* @throws RemoteException
* @throws WebServiceFault
*/
public static long importCandidate() throws AxisFault, RemoteException, WebServiceFault {
CandidateServiceStub stub =
new CandidateServiceStub("https://hostname/enterprise/soap?ServiceName=CandidateService");
HttpTransportProperties.Authenticator auth = new HttpTransportProperties.Authenticator();
auth.setUsername("Username");
auth.setPassword("Password");
auth.setPreemptiveAuthentication(true); // activate preemptive authentication
stub._getServiceClient().getOptions().setProperty(HTTPConstants.AUTHENTICATE, auth);
CreateDocument createDoc = CreateDocument.Factory.newInstance();
CreateDocument.Create create = createDoc.addNewCreate();
Candidate candidate = create.addNewCandidate();
SearchableStringField address = candidate.addNewAddress();
address.setStringValue("123 Main Street");
SearchableStringField address2 = candidate.addNewAddress2();
address2.setStringValue("Apartment 1");
SearchableStringField lastName = candidate.addNewLastName();
lastName.setStringValue("XYZ");
SearchableStringField firstName = candidate.addNewFirstName();
firstName.setStringValue("XYZ");
SearchableStringField emailAddress = candidate.addNewEmailAddress();
emailAddress.setStringValue("xxx@invalid.address.com");
CreateResponseDocument createResponse = stub.create(createDoc);
long val = createResponse.getCreateResponse().getNumber();
return val;
}
public CandidateDC() {
super();
}
}
If you get the "java.net.SocketException: Software caused connection abort: recv failed" issue -
More Details
