Connect Azure Service Bus with Android

Question

I just wrote a java program (jdk 1.7) that lists all the topics on my service bus and displays the name of each topic in stdout:

try { String namespace = "myservicebus"; // from azure portal String issuer = "owner"; // from azure portal String key = "asdjklasdjklasdjklasdjklasdjk"; // from azure portal Configuration config = ServiceBusConfiguration.configureWithWrapAuthentication( namespace, issuer, key, ".servicebus.windows.net", "-sb.accesscontrol.windows.net/WRAPv0.9"); ServiceBusContract service = ServiceBusService.create(config); ListTopicsResult result = service.listTopics(); List<TopicInfo> infoList = result.getItems(); for(TopicInfo info : infoList){ System.out.println( info.getPath()); } } catch (Exception e) { e.printStackTrace(); } 

Now I'm trying to run this example in a simple Android project (Android 4.2), but it will not work. Runtime always causes the following error:

 java.lang.RuntimeException: Service or property not registered: com.microsoft.windowsazure.services.serviceBus.ServiceBusContract 

Has anyone successfully connected to an Android device (or emulator) on a service bus?

Does Microsoft Azure-Java-SDK support android projects?

Thank you in advance

Answer 1

This error occurs because the generated apks do not include (delete) ServiceLoader information (in accordance with META-INF / services). You can test yourself by removing it from the created jar, and you will see that the same error appears. The documentation says that it is now supported, but I found problems with its use.

http://developer.android.com/reference/java/util/ServiceLoader.html

You can manually include data in apk using ant

Store META-INF / services files in apk

After debugging 10 minutes, manually deleting classes, including META-INF / services, etc., I found that the Azure SDK uses some classes not supported by Android (javax.ws. *), And any work works for me.

Therefore, I would recommend using the REST API in Android environments, find below the source code that I used to send messages to the topic.

 private static String generateSasToken(URI uri) { String targetUri; try { targetUri = URLEncoder .encode(uri.toString().toLowerCase(), "UTF-8") .toLowerCase(); long expiresOnDate = System.currentTimeMillis(); int expiresInMins = 20; // 1 hour expiresOnDate += expiresInMins * 60 * 1000; long expires = expiresOnDate / 1000; String toSign = targetUri + "\n" + expires; // Get an hmac_sha1 key from the raw key bytes byte[] keyBytes = sasKey.getBytes("UTF-8"); SecretKeySpec signingKey = new SecretKeySpec(keyBytes, "HmacSHA256"); // Get an hmac_sha1 Mac instance and initialize with the signing key Mac mac = Mac.getInstance("HmacSHA256"); mac.init(signingKey); // Compute the hmac on input data bytes byte[] rawHmac = mac.doFinal(toSign.getBytes("UTF-8")); // using Apache commons codec for base64 // String signature = URLEncoder.encode( // Base64.encodeBase64String(rawHmac), "UTF-8"); String rawHmacStr = new String(Base64.encodeBase64(rawHmac, false),"UTF-8"); String signature = URLEncoder.encode(rawHmacStr, "UTF-8"); // construct authorization string String token = "SharedAccessSignature sr=" + targetUri + "&sig=" + signature + "&se=" + expires + "&skn=" + sasKeyName; return token; } catch (Exception e) { throw new RuntimeException(e); } } public static void Send(String topic, String subscription, String msgToSend) throws Exception { String url = uri+topic+"/messages"; HttpClient client = new DefaultHttpClient(); HttpPost post = new HttpPost(url); // Add header String token = generateSasToken(new URI(uri)); post.setHeader("Authorization", token); post.setHeader("Content-Type", "text/plain"); post.setHeader(subscription, subscription); StringEntity input = new StringEntity(msgToSend); post.setEntity(input); System.out.println("Llamando al post"); HttpResponse response = client.execute(post); System.out.println("Response Code : " + response.getStatusLine().getStatusCode()); if (response.getStatusLine().getStatusCode() != 201) throw new Exception(response.getStatusLine().getReasonPhrase()); } 

See the Azure REST API information for more information.