ActiveMQ: कतार लुकअप के साथ समस्या

Question

मैंने इसे documentation में वर्णित Activemq.xml (ActiveMQ संस्करण 5.2.0) में कॉन्फ़िगर करके एक कतार स्थापित की है। हालांकि कतार JConsole में दिखाई दे रहा है (

Hashtable properties = new Hashtable(); 
properties.put(Context.INITIAL_CONTEXT_FACTORY, 
    "org.apache.activemq.jndi.ActiveMQInitialContextFactory"); 
properties.put(Context.PROVIDER_URL, "tcp://localhost:61616"); 

context = new InitialContext(properties); 

factory = (ConnectionFactory) context.lookup("ConnectionFactory"); 
connection = factory.createConnection(); 
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
queueName = "DUMMY"; // which can be either FOO.BAR or DUMMY 
dest = (Destination) context.lookup(queueName); 

मैं निम्न त्रुटि receveing ​​हूँ:

<destinations> 
    <queue physicalName="FOO.BAR" /> 
    <queue physicalName="DUMMY" /> 
</destinations> 

मैं इसे निम्न कोड के साथ (एक ही मेजबान पर) जावा से उपयोग करने की कोशिश कर रहा हूँ वृक्ष/org.apache.activemq/कतार):

javax.naming.NameNotFoundException: DUMMY 

कृपया मुझे बताएं कि मैं क्या गलत कर रहा हूं। बहुत बहुत शुक्रिया!

Answer 1

सबसे पहले आपको explicitly create any queues in the broker नहीं है हालांकि यह कोई नुकसान नहीं करता है।

ब्रोकर में उपलब्ध गंतव्यों को किसी भी प्रकार के जेएनडीआई नाम का उपयोग करके आपके लिए जेएनडीआई संदर्भ में ऑटो-जादुई रूप से मैप नहीं किया गया है।

आप यह explicitly as described here कर सकते हैं। आप JNDI के ऑटो जादुई आबादी चाहते हैं तो JNDI नाम (Dynamically creating destinations में वर्णित है) आप देखने

Answer 2

हम्म .. अच्छी तरह से जब मैं एक कतार में सुनना चाहते हैं के रूप में dynamicQueues की JNDI नामकरण परंपरा/डमी का उपयोग मैं आमतौर पर ऐसा कुछ करता हूं। (javax.jms से आयात)

कतार कतार;

// Connect to ActiveMQ 
    ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(messageBrokerURL); 
    connection = factory.createConnection(); 
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 

    // List to Dummy Queue 
    queue = session.createQueue("DUMMY"); 
    messageConsumer = session.createConsumer(queue); 
    messageConsumer.setMessageListener(queueHandler); 

    // Start the connection 
    connection.start(); 

और सुनिश्चित करें कि आपका हैंडलर MessageListener लागू करता है।