activemq Javaコードのユーザ名とパスワードでキュー名を指定する必要があります

Question

activeMQキューに接続する単純なJavaコードを書き込もうとしていますが、Hello WorldのactiveMQサイトの例に実質的に従うthisリソースがオンラインです。私は、キュー名と一緒にユーザー名とパスワードを指定しようとしていると私はオンライン任意の有用なリソースを見つけることができませんよ、ので、任意のヘルプは高く評価されるだろう。

私はプロデューサーのコードに以下の変更を行って、私は正確にユーザー名とパスワードを指定していた場合、私は、工場名を指定するかどうかはわかりませんと？ここ

  // First create a connection 
      InitialContext initCtx = new InitialContext(); 
      javax.jms.ConnectionFactory qcf = (javax.jms.ConnectionFactory) initCtx.lookup(factoryName); 
      Connection connection = qcf.createConnection("admin","admin"); 
      connection.start(); 

Answer 1

は、ここでは一例

 Properties props = new Properties(); 
     props.put(Context.INITIAL_CONTEXT_FACTORY, 
       "org.apache.activemq.jndi.ActiveMQInitialContextFactory"); 
     props.setProperty(Context.PROVIDER_URL, 
       "tcp://localhost:61616"); 
     props.put("topic." + "TOPICNAME", "TOPICNAME"); 
     InitialContext ic = new InitialContext(props); 
     ConnectionFactory cf1 = (ConnectionFactory) ic.lookup("ConnectionFactory"); 
     writeDestination = (Topic) ic.lookup("TOPICNAME"); 
     writeDestConnection = cf1.createConnection("user", "pwd"); 
     writeDestConnection.setClientID("durableSubscriber_" + "TOPICNAME"); 
     writeDestSession = writeDestConnection.createSession(false,Session.AUTO_ACKNOWLEDGE); 
     writeDestProducer = writeDestSession.createProducer(writeDestination); 
     writeDestConnection.start(); 
     TextMessage message = writeDestSession.createTextMessage(json); 
     message.setStringProperty("clientID", "ifYouNeed"); 
     writeDestProducer.send(message); 

http://activemq.apache.org/jndi-support.html

あるJNDIのない別の例である：あなたの答えのための

public static void main(String[] args) throws JMSException { 
    Connection conn = null; 
    try { 
     ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("tcp://localhost:61616"); 
     conn = cf.createConnection("user", "pwd"); 
     Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); 
     MessageConsumer consumer = session.createConsumer(session.createQueue("queueName")); 
     conn.start(); 
     TextMessage msg = null; 
     while ((msg = (TextMessage) consumer.receive()) != null) { 
      System.out.println("Received message is: " + msg.getText()); 
     } 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } finally { 
     if (conn != null) { 
      try { 
       conn.close(); 
      } catch (Exception e) { 
      } 
     } 
    } 
}