Skip to content

Task 1537: Updated sample code to use TLS 1.2 #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Nov 13, 2015
Merged

Task 1537: Updated sample code to use TLS 1.2 #1

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
28 changes: 21 additions & 7 deletions java/message-hub-kafka-ssl/src/com/example/RESTRequest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;

public class RESTRequest
{
Expand All @@ -46,7 +48,7 @@ public RESTRequest(String baseUrl, String apiKey)
*/
public String get(String target, boolean acceptHeader)
{
HttpURLConnection connection = null;
HttpsURLConnection connection = null;

if(!target.startsWith("/"))
{
Expand All @@ -55,9 +57,13 @@ public String get(String target, boolean acceptHeader)

try
{
// Create connection to the REST URL.
URL url = new URL(baseUrl + target);
connection = (HttpURLConnection)url.openConnection();
// Create secure connection to the REST URL.
SSLContext sslContext = SSLContext.getInstance("TLSv1.2");
sslContext.init(null, null, null);

URL url = new URL(baseUrl + target);
connection = (HttpsURLConnection)url.openConnection();
connection.setSSLSocketFactory(sslContext.getSocketFactory());
connection.setRequestMethod("GET");
// Apply API key header and kafka content type Accept header if
// the 'acceptHeader' flag is set to true.
Expand Down Expand Up @@ -110,7 +116,7 @@ public String get(String target, boolean acceptHeader)
*/
public String post(String target, String body, int[] ignoredErrorCodes)
{
HttpURLConnection connection = null;
HttpsURLConnection connection = null;
int responseCode = 0;

if(!target.startsWith("/"))
Expand All @@ -120,14 +126,22 @@ public String post(String target, String body, int[] ignoredErrorCodes)

try
{
// Create connection to the REST URL.


// Create secure connection to the REST URL.
SSLContext sslContext = SSLContext.getInstance("TLSv1.2");
sslContext.init(null, null, null);

URL url = new URL(baseUrl + target);
connection = (HttpURLConnection)url.openConnection();
connection = (HttpsURLConnection)url.openConnection();
connection.setSSLSocketFactory(sslContext.getSocketFactory());
connection.setDoOutput(true);
connection.setRequestMethod("POST");

// Apply headers, in this case, the API key and Kafka content type.
connection.setRequestProperty("X-Auth-Token", this.apiKey);
connection.setRequestProperty("Content-Type", "application/json");


// Send the request, writing the body data
// to the output stream.
Expand Down