Java Example
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.io.StringReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;
import javax.xml.bind.JAXBContext;
import javax.xml.bind.Unmarshaller;
import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.transform.stream.StreamSource;
import org.eclipse.persistence.jaxb.JAXBContextProperties;
import org.eclipse.persistence.jaxb.xmlmodel.ObjectFactory;
public class TestUpsideRESTAPI {
public static final String APIEndPoint = "https://secureapi.upsidewireless.com"; // or "http://api.upsidewireless.com" public static final String APICredential_Token ="xxxxxxxx-8e4b-405b-998c-a580bf593b76"; public static final String APICredential_Signature = "xxxxxxxxfyqQx95Gxxxxxxxx"; private static String SMSMessageUrl = String.format("%s/RESTv1/%s/Message", APIEndPoint, APICredential_Token);
public static void main(String[] argv) throws Exception { HttpURLConnection connection = null; boolean acceptJSON = false; System.out.println("SMS Message URL: " + SMSMessageUrl + "\n"); try { URL smsMessageUrl = new URL(SMSMessageUrl); connection = (HttpURLConnection)smsMessageUrl.openConnection();
connection.setRequestMethod("POST"); connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); connection.setRequestProperty("Accept", acceptJSON ? "application/json" : "application/xml"); connection.setRequestProperty("User-Agent", "UpsideJavaAgent"); connection.setConnectTimeout(100 * 1000); // 100 seconds connection.setReadTimeout(300 * 1000); // 300 seconds connection.setDoOutput(true); String smsPostData = "signature=%s"; smsPostData += "&type=%s"; smsPostData += "&message=%s"; smsPostData += "&recipient=%s"; smsPostData += "&encoding=%s"; String type = "sms"; // see type list on wiki String message = "test sms message"; String recipient = "16047891236"; // number in E.164 format String encoding = "7"; // 7, 8 or 16 message = URLEncoder.encode(message, "UTF-8"); smsPostData = String.format(smsPostData, APICredential_Signature, type, message, recipient, encoding); System.out.println("Post Data: " + smsPostData + "\n"); PrintWriter pw = new PrintWriter(connection.getOutputStream()); pw.println(smsPostData); pw.close();
InputStream input = null; try { input = connection.getInputStream(); } catch (Exception e) { input = connection.getErrorStream(); } StringBuffer sbResponse = new StringBuffer(1024); BufferedReader reader = new BufferedReader(new InputStreamReader(input)); String inputLine = null; while ((inputLine = reader.readLine()) != null) { sbResponse.append(inputLine); } reader.close(); String responseString = sbResponse.toString(); System.out.println("HTTP Response: " + responseString + "\n"); RestResponse restResponse = null; if (acceptJSON) { Map<String, Object> properties = new HashMap<String, Object>(2); properties.put(JAXBContextProperties.MEDIA_TYPE, "application/json"); properties.put(JAXBContextProperties.JSON_INCLUDE_ROOT, false); JAXBContext jaxbContext = JAXBContext.newInstance(new Class[] {RestResponse.class, ObjectFactory.class}, properties); Unmarshaller unmarshaller = jaxbContext.createUnmarshaller(); StringReader sr = new StringReader(responseString); StreamSource json = new StreamSource(sr); restResponse = unmarshaller.unmarshal(json, RestResponse.class).getValue(); // or use your favourite method to parse JSON object } else { JAXBContext jaxbContext = JAXBContext.newInstance(RestResponse.class); Unmarshaller unmarshaller = jaxbContext.createUnmarshaller(); StringReader sr = new StringReader(responseString); restResponse = (RestResponse) unmarshaller.unmarshal(sr); // or use your favourite method to parse XML object } if (restResponse != null) { System.out.println("Rest Response - HasException: " + restResponse.isHasException()); System.out.println("Rest Response - Token: " + restResponse.getToken()); if (restResponse.isHasException()) { System.out.println("Rest Response - RestException.ErrorCode: " + restResponse.getRestException().getErrorCode()); System.out.println("Rest Response - RestException.Message: " + restResponse.getRestException().getMessage()); if (restResponse.getRestException().getStatus() != null) System.out.println("Rest Response - RestException.Status: " + restResponse.getRestException().getStatus()); } else { System.out.println("Rest Response - SMSMessage.Status: " + restResponse.getSMSMessage().getStatus()); System.out.println("Rest Response - SMSMessage.Recipient: " + restResponse.getSMSMessage().getRecipient()); System.out.println("Rest Response - SMSMessage.Body: " + restResponse.getSMSMessage().getBody()); System.out.println("Rest Response - SMSMessage.Type: " + restResponse.getSMSMessage().getType()); System.out.println("Rest Response - SMSMessage.TrackingId: " + restResponse.getSMSMessage().getTrackingId()); if ("REJECTED".equals(restResponse.getSMSMessage().getStatus())) System.out.println("Rest Response - SMSMessage.RejectReason: " + restResponse.getSMSMessage().getRejectReason()); } } else { System.out.println("Can't get rest response object"); } } catch (Exception e) { System.out.println("Error in calling REST API - " + e.getMessage()); e.printStackTrace(); } finally { if (connection != null) { connection.disconnect(); } } }
}
@XmlRootElement(name="RestResponse") @XmlAccessorType(XmlAccessType.FIELD) class RestResponse {
@XmlElement(name = "HasException") private boolean HasException; @XmlElement(name = "Token") private String Token;
@XmlElement(name = "SMSMessage") private SMSMessage SMSMessage; @XmlElement(name = "RestException") private RestException RestException; public boolean isHasException() { return HasException; } public void setHasException(boolean hasException) { HasException = hasException; }
public String getToken() { return Token; }
public void setToken(String token) { Token = token; }
public SMSMessage getSMSMessage() { return SMSMessage; }
public void setSMSMessage(SMSMessage sMSMessage) { SMSMessage = sMSMessage; }
public RestException getRestException() { return RestException; }
public void setRestException(RestException restException) { RestException = restException; }
}
@XmlAccessorType(XmlAccessType.FIELD) class SMSMessage {
@XmlElement(name = "Status") private String Status; @XmlElement(name = "Recipient") private String Recipient; @XmlElement(name = "Body") private String Body; @XmlElement(name = "Type") private String Type; @XmlElement(name = "TrackingId") private String TrackingId; @XmlElement(name = "RejectReason") private String RejectReason; public String getStatus() { return Status; } public void setStatus(String status) { Status = status; }
public String getRecipient() { return Recipient; }
public void setRecipient(String recipient) { Recipient = recipient; }
public String getBody() { return Body; }
public void setBody(String body) { Body = body; }
public String getType() { return Type; }
public void setType(String type) { Type = type; }
public String getTrackingId() { return TrackingId; }
public void setTrackingId(String trackingId) { TrackingId = trackingId; }
public String getRejectReason() { return RejectReason; }
public void setRejectReason(String rejectReason) { RejectReason = rejectReason; }
}
@XmlAccessorType(XmlAccessType.FIELD) class RestException {
@XmlElement(name = "ErrorCode") private int ErrorCode; @XmlElement(name = "Message") private String Message; @XmlElement(name = "Status") private String Status; public int getErrorCode() { return ErrorCode; } public void setErrorCode(int errorCode) { ErrorCode = errorCode; }
public String getMessage() { return Message; }
public void setMessage(String message) { Message = message; }
public String getStatus() { return Status; }
public void setStatus(String status) { Status = status; }
}
Note: In order to run this sample, you need include MOXy library, as well as JAXB if no built-in JAXB in your JDK