Databases
StackOverflow2013
Postsdbo
PO
 

Note that there are some explanatory texts on larger screens.

plurals
  1. PO
    primarykey
    data
    text
    <p>We are going to create a console based application using multithreading. So create an java project for console application.</p> <p>Now follow these steps.......... </p> <ol> <li><p>Add javax.jms.jar, activemq-all-5.3.0.jar, log4j-1.2.15.jar to your project library. (You can download all of above jar files from <a href="http://www.jarfinder.com/" rel="noreferrer">http://www.jarfinder.com/</a> .</p></li> <li><p>create a file naming jndi.properties and paste these following texts .. ( Deatils for jndi.properties just Google it)</p></li> </ol> <pre><code> # START SNIPPET: jndi java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory # use the following property to configure the default connector java.naming.provider.url = tcp://localhost:61616 # use the following property to specify the JNDI name the connection factory # should appear as. #connectionFactoryNames = connectionFactory, queueConnectionFactory, topicConnectionFactry connectionFactoryNames = connectionFactory, queueConnectionFactory, topicConnectionFactry # register some queues in JNDI using the form # queue.[jndiName] = [physicalName] queue.MyQueue = example.MyQueue # register some topics in JNDI using the form # topic.[jndiName] = [physicalName] topic.MyTopic = example.MyTopic # END SNIPPET: jndi </code></pre> <hr> <p>Add JMSConsumer.java</p> <pre><code> import javax.jms.*; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; public class JMSConsumer implements Runnable{ private static final Log LOG = LogFactory.getLog(JMSConsumer.class); public void run() { Context jndiContext = null; ConnectionFactory connectionFactory = null; Connection connection = null; Session session = null; MessageConsumer consumer = null; Destination destination = null; String sourceName = null; final int numMsgs; sourceName= "MyQueue"; numMsgs = 1; LOG.info("Source name is " + sourceName); /* * Create a JNDI API InitialContext object */ try { jndiContext = new InitialContext(); } catch (NamingException e) { LOG.info("Could not create JNDI API context: " + e.toString()); System.exit(1); } /* * Look up connection factory and destination. */ try { connectionFactory = (ConnectionFactory)jndiContext.lookup("queueConnectionFactory"); destination = (Destination)jndiContext.lookup(sourceName); } catch (NamingException e) { LOG.info("JNDI API lookup failed: " + e); System.exit(1); } try { connection = connectionFactory.createConnection(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); consumer = session.createConsumer(destination); connection.start(); try { Thread.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } MessageListener listener = new MyQueueMessageListener(); consumer.setMessageListener(listener ); //Let the thread run for some time so that the Consumer has suffcient time to consume the message try { Thread.sleep(5000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (JMSException e) { LOG.info("Exception occurred: " + e); } finally { if (connection != null) { try { connection.close(); } catch (JMSException e) { } } } } } </code></pre> <p>Add JMSProducer.java</p> <pre><code> import javax.jms.*; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; public class JMSProducer implements Runnable{ private static final Log LOG = LogFactory.getLog(JMSProducer.class); public JMSProducer() { } //Run method implemented to run this as a thread. public void run(){ Context jndiContext = null; ConnectionFactory connectionFactory = null; Connection connection = null; Session session = null; Destination destination = null; MessageProducer producer = null; String destinationName = null; final int numMsgs; destinationName = "MyQueue"; numMsgs = 5; LOG.info("Destination name is " + destinationName); /* * Create a JNDI API InitialContext object */ try { jndiContext = new InitialContext(); } catch (NamingException e) { LOG.info("Could not create JNDI API context: " + e.toString()); System.exit(1); } /* * Look up connection factory and destination. */ try { connectionFactory = (ConnectionFactory)jndiContext.lookup("queueConnectionFactory"); destination = (Destination)jndiContext.lookup(destinationName); } catch (NamingException e) { LOG.info("JNDI API lookup failed: " + e); System.exit(1); } /* * Create connection. Create session from connection; false means * session is not transacted.create producer, set the text message, set the co-relation id and send the message. */ try { connection = connectionFactory.createConnection(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); producer = session.createProducer(destination); TextMessage message = session.createTextMessage(); for (int i = 0; i </pre> <hr> <p>Add MyQueueMessageListener.java</p> <pre><code> import java.io.*; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import javax.jms.*; public class MyQueueMessageListener implements MessageListener { private static final Log LOG = LogFactory.getLog(MyQueueMessageListener.class); /** * */ public MyQueueMessageListener() { // TODO Auto-generated constructor stub } /** (non-Javadoc) * @see javax.jms.MessageListener#onMessage(javax.jms.Message) * This is called on receving of a text message. */ public void onMessage(Message arg0) { LOG.info("onMessage() called!"); if(arg0 instanceof TextMessage){ try { //Print it out System.out.println("Recieved message in listener: " + ((TextMessage)arg0).getText()); System.out.println("Co-Rel Id: " + ((TextMessage)arg0).getJMSCorrelationID()); try { //Log it to a file BufferedWriter outFile = new BufferedWriter(new FileWriter("MyQueueConsumer.txt")); outFile.write("Recieved message in listener: " + ((TextMessage)arg0).getText()); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } }else{ System.out.println("~~~~Listener : Error in message format~~~~"); } } } </code></pre> <hr> <p>Add SimpleApp.java</p> <pre> public class SimpleApp { //Run the producer first, then the consumer public static void main(String[] args) throws Exception { runInNewthread(new JMSProducer()); runInNewthread(new JMSConsumer()); } public static void runInNewthread(Runnable runnable) { Thread brokerThread = new Thread(runnable); brokerThread.setDaemon(false); brokerThread.start(); } } </code></pre> <hr> <p>Now run SimpleApp.java class. </p> <p>All da best. Happy coding.</p>
    singulars
    1. This table or related slice is empty.
    1. POActiveMQ and JMS : Basic steps for novice
      singulars
      1. PTQuestion
    1. PTAnswer
    1. USPankaj Kumar
    1. USPankaj Kumar
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. POActiveMQ and JMS : Basic steps for novice
      singulars
      1. PTQuestion
    1. This table or related slice is empty.
    1. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTAcceptedByOriginator
    2. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTUpMod
    3. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTUpMod
    1. COhi, Thanks for your answer. Could you please throw some light on this and help me out. Thanks for your time.
      singulars
      1. PO
      1. USKumar
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload