Thanks for your response dejan.Below is the code for checking whether the
configured vm broker url in context_activemq.xml(see first post) is working
or not.even if i am giving wrong username and password its connecting its
not showing any exception as "invalid username" Is the below code is correct
for checking vm broker url?can you help me for this?
public class ExampleCheck {
private static final org.apache.commons.logging.Log log =
org.apache.commons.logging.LogFactory
.getLog(ExampleCheck.class);
public static void main(String[] args) {
ConnectionFactory connectionFactory = null;
Connection connection = null;
Session session = null;
Queue queue = null;
MessageProducer producer = null;
final int NUM_MSGS = 20;
try {
connectionFactory = new
ActiveMQConnectionFactory("vm://brokerDefault");
log.info("Got ConnectionFactory");
connection =
connectionFactory.createConnection("aaaaaaaa", "pass");
log.info("Got Connection");
session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
log.info("Got Session");
queue =
session.createQueue("jms:queue:Testsubscription1.outbound.queue");
log.info("Got Destination");
producer = session.createProducer(queue);
log.info("Got Producer");
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
TextMessage message = session.createTextMessage();
for (int i = 0; i < NUM_MSGS; i++) {
message.setText("This is message " + (i + 1));
log.info("Sending message: " +
message.getText());
Thread.sleep(5000);
producer.send(message);
}
producer.send(session.createMessage());
} catch (Exception e1) {
e1.printStackTrace();
} finally {
if (connection != null) {
try {
connection.close();
} catch (JMSException e) {
}
}
}
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Is-simpleauthentication-required-for-vm-broker-url-in-activemq-tp4668721p4668773.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
