Necesito una biblioteca de cliente de java stomp que funcione con ssl

Question

Estoy probando varias bibliotecas de stomp para java (gozirra, stompj, activemq). Todas estas bibliotecas tienen poca documentación, como tener solo un ejemplo, y tengo un problema grave:

Necesito compatibilidad con SSL.

El protocolo stomp + ssl existe y es compatible con activemq pero no puedo encontrar un cliente Java que lo admita.

Answer 1

Con la biblioteca de activemq hacerlo de esta manera:

   System.setProperty("javax.net.ssl.keyStore", 
      "/home/foo/.keystore/client.ks"); 
    System.setProperty("javax.net.ssl.keyStorePassword", "changeme"); 
    System.setProperty("javax.net.ssl.trustStore", 
      "/home/foo/.keystore/client.ts"); 

    StompConnection connection = new StompConnection(); 
    SSLSocketFactory factory = (SSLSocketFactory) SSLSocketFactory 
      .getDefault(); 
    SSLSocket sslsocket = (SSLSocket) factory.createSocket("127.0.0.1", 
      61612); 
    connection.open(sslsocket); 

Answer 2

I conocer this forum discussion sobre JMS en Android, que hace referencia the experimental Stomp API incluido en ActiveMQ 5,2 y mayor (ejemplo copiado a continuación)

También se menciona que la REST API podría ser un mejor ajuste para los dispositivos móviles, permitiendo que el estado que se mantenga puramente en el corredor.

StompConnection connection = new StompConnection(); 
connection.open("localhost", 61613); 

connection.connect("system", "manager"); 
StompFrame connect = connection.receive(); 
if (!connect.getAction().equals(Stomp.Responses.CONNECTED)) { 
    throw new Exception ("Not connected"); 
} 

connection.begin("tx1"); 
connection.send("/queue/test", "message1", "tx1", null); 
connection.send("/queue/test", "message2", "tx1", null); 
connection.commit("tx1"); 

connection.subscribe("/queue/test", Subscribe.AckModeValues.CLIENT); 

connection.begin("tx2"); 

StompFrame message = connection.receive(); 
System.out.println(message.getBody()); 
connection.ack(message, "tx2"); 

message = connection.receive(); 
System.out.println(message.getBody()); 
connection.ack(message, "tx2"); 

connection.commit("tx2"); 
connection.disconnect(); 

Answer 3

No asegurarse de que funciona en Android, pero vale la pena probar es el cliente FuseSource StompJMS disponibles en Github. Utiliza la biblioteca hwatdispatch, que tiene transportes TCP y SSL estándar integrados. Vale la pena intentarlo de todos modos.