मुझे एक जावा स्टॉम्प क्लाइंट लाइब्रेरी की आवश्यकता है जो एसएसएल

Question

के साथ काम करता है मैं जावा (गोज़ीरा, स्टॉम्प, एक्टिवैक) के लिए कई स्टॉम्प लाइब्रेरीज़ की कोशिश कर रहा हूं। इन सभी पुस्तकालयों में खराब दस्तावेज हैं, जैसे कि केवल एक उदाहरण है, और मुझे एक गंभीर समस्या है:

मुझे SSL समर्थन की आवश्यकता है।

स्टॉम्प + एसएसएल प्रोटोकॉल मौजूद है और सक्रिय एमक्यू द्वारा समर्थित है लेकिन मैं जावा क्लाइंट को ढूंढने में सक्षम नहीं हूं।

Answer 1

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); 

Answer 2

मैं JMS Android पर है, जो संदर्भ देता the experimental Stomp API ActiveMQ 5.2 और अधिक से अधिक (उदाहरण के नीचे की नकल की)

भी उल्लेख किया

कि REST API, मोबाइल उपकरणों के लिए एक बेहतर फिट हो सकता है राज्य बनाए रखा जाना करने के लिए अनुमति है में शामिल बारे में this forum discussion पाया पूरी तरह से दलाल पर।

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

सुनिश्चित नहीं हैं कि यह Android पर काम करता है, लेकिन लायक एक कोशिश FuseSource StompJMS ग्राहक Github पर उपलब्ध है। यह hwatdispatch लाइब्रेरी का उपयोग करता है जिसमें मानक टीसीपी और एसएसएल ट्रांसपोर्ट दोनों निर्मित होते हैं। वैसे भी एक शॉट के लायक है।