2013-01-09 6 views
5

का उपयोग करके मैं जानना चाहूंगा कि कोई जेएम और एक्टिबैक संदेश पढ़ने के बिना कोई तरीका है या नहीं ?? मुझे पता है कि कतार से संदेश खपत किए जा सकते हैं, फिर भी मैं इस सवाल से पूछना चाहता हूं। !!उन्हें बिना उपभोग किए जेएमएस संदेशों को कैसे पढ़ा जाए - ActiveMQ

उत्तर

5

आप JMS QueueBrowser के माध्यम से एक पंक्ति पर संदेश ब्राउज़ कर सकते हैं, या ActiveMQ में आप JMX से अधिक या आदेशों लाइन उपकरणों के साथ सामग्री ब्राउज़ कर सकते हैं:

ActiveMQ console tools

JMS QueueBrowser API

ActiveMQ JMX

+0

धन्यवाद टीआईएम मैं कार्यक्षमता को लागू करने के लिए एक webservice लिखने की योजना बना रहा हूं .. !!! तो मैं बेहतर होगा कि मैं सादा जावा कोड – user1697202

+0

का उपयोग करके इसे लागू कर सकता हूं क्या आप एक जेएमएस क्यूई ब्रोसर सादा जावा कोड पर विचार नहीं करेंगे? –

+0

मुझे लगता है कि कुछ भ्रम है क्योंकि "JMS QueueBrowser API" लिंक एक ActiveMQ पृष्ठ इंगित कर रहा है। मुझे लगता है कि शायद आप इस यूआरएल को साझा करना चाहते थे: https://docs.oracle.com/javaee/7/api/javax/jms/QueueBrowser.html – mojoken

1

एक और विकल्प संदेशों को "उपभोग" करना है, लेकिन केवल एक लेनदेन में, फिर जब आप पूरा कर लेंगे, इसे वापस रोल करें, लेकिन एक ब्राउज़र बेहतर हो सकता है क्योंकि यह "क्या है के लिए "जैसा था।

यदि आप सिर्फ एक विशेष संदेश की तलाश में हैं, और मैन्युअल करेंगे, तो आप "आरएसएस फ़ीड" बटन पर क्लिक करके एक सक्रिय एमक्यू के लिए संदेशों और उनकी सामग्री को देख सकते हैं (मुझे लगता है कि कम से कम कुछ) यूआई में जो मूल रूप से उन्हें स्क्रीन पर डंप करता है। "परमाणु फ़ीड" विकल्प "आरएसएस" एक एफडब्ल्यूआईडब्ल्यू से तेज़ी से लोड होता प्रतीत होता है।

2
Rather than using Message-consumers you need to use the Queue-Browser class for doing this 

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616"); 
      Connection connection = connectionFactory.createConnection("admin","admin"); 
      connection.start(); 
      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
      Queue queue = session.createQueue("Test"); 
      QueueBrowser queueBrowser = session.createBrowser(queue); 
Enumeration msgs = queueBrowser.getEnumeration(); 
while (msgs.hasMoreElements()) { 
//do your things here 
} 
संबंधित मुद्दे