Я пробую несколько stomp-библиотек для java (gozirra, stompj, activemq). Все эти библиотеки имеют плохую документацию, например, только один пример, и у меня есть серьезная проблема:
Мне нужна поддержка SSL.
Протокол stomp+ssl существует и поддерживается activemq, но я не могу найти клиент Java, который его поддерживает.
С библиотекой из activemq делаем так:
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);
Я нашел эту дискуссию на форуме о JMS на Android, которая ссылается на экспериментальный API Stomp, включенный в ActiveMQ 5.2 и выше (пример скопирован ниже)
Также упоминается, что REST API может лучше подходить для мобильных устройств, позволяя сохранять состояние. чисто у брокера.
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();
Не уверен, что это работает на Android, но стоит попробовать клиент FuseSource StompJMS, доступный на Github. Он использует библиотеку hwatdispatch, которая имеет встроенные стандартные транспорты TCP и SSL. В любом случае стоит попробовать.
