Ahhhh! That would do it. :)
On Tue, Jun 29, 2010 at 2:28 PM, Mark <[email protected]> wrote: > Nevermind. I found that I had a selector set on the MessageListener. > > > On Tue, Jun 29, 2010 at 2:02 PM, Mark <[email protected]> wrote: >> Here is the test message sender that I am using... >> >> public class Sender { >> >> public static final String JMS_SERVER_URL = "tcp://127.0.0.1:61616"; >> public static final String JMS_DEST = "example.A"; >> private Session session; >> private MessageProducer producer; >> private Destination destination; >> >> public Sender() throws JMSException { >> >> ActiveMQConnectionFactory connFactory = new >> ActiveMQConnectionFactory(JMS_SERVER_URL); >> >> QueueConnection connection = connFactory.createQueueConnection(); >> session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); >> destination = session.createQueue(JMS_DEST); >> producer = session.createProducer(destination); >> connection.start(); >> } >> >> public void sendData() throws JMSException { >> >> int i = 0; >> for(int j=0; j<10; j++){ >> >> System.out.println("Sending message " + i); >> TextMessage message = session.createTextMessage("Header " + i); >> System.out.println("Destination = " + producer.getDestination()); >> producer.send(message); >> >> try { >> Thread.sleep(200); >> } catch (InterruptedException ex) { >> >> Logger.getLogger(Sender.class.getName()).log(Level.SEVERE, null, ex); >> } >> >> i++; >> } >> } >> >> public static void main(String[] args) throws JMSException { >> >> Sender sender = new Sender(); >> sender.sendData(); >> } >> } >> >> >> >> On Tue, Jun 29, 2010 at 12:38 PM, James Carman >> <[email protected]> wrote: >>> How are you sending your message? Can we see that code? >>> >>> On Tue, Jun 29, 2010 at 11:46 AM, Mark <[email protected]> wrote: >>>> I tried putting in a Thread.sleep(60*1000), but the messages still do >>>> not show up in the listener. >>>> >>>> >>>> >>>> On Mon, Jun 28, 2010 at 7:16 PM, Willem Jiang <[email protected]> >>>> wrote: >>>>> After you started the camel context, you need to use some sleep to avoid >>>>> the >>>>> main thread exits otherwise camel route will stop work, >>>>> >>>>> Willem >>>>> ---------------------------------- >>>>> Apache Camel, Apache CXF committer >>>>> Open SOA http://www.fusesource.com >>>>> Blog http://willemjiang.blogspot.com >>>>> Tiwtter http://twitter.com/willemjiang >>>>> >>>>> Mark wrote: >>>>>> >>>>>> Hello, >>>>>> >>>>>> I am working on creating a simple route using camel and java. I have >>>>>> the following code: >>>>>> >>>>>> public class CamelMain { >>>>>> public static void main(String[] args) throws Exception { >>>>>> CamelContext context = new DefaultCamelContext(); >>>>>> ConnectionFactory connectionFactory = new >>>>>> ActiveMQConnectionFactory("tcp://127.0.0.1:61616"); >>>>>> context.addComponent("test-jms", >>>>>> JmsComponent.jmsComponent(connectionFactory)); >>>>>> >>>>>> context.addRoutes(new RouteBuilder() { >>>>>> public void configure() { >>>>>> >>>>>> from("test-jms:queue:example.A").to("test-jms:queue:example.B"); >>>>>> } >>>>>> }); >>>>>> >>>>>> context.start(); >>>>>> } >>>>>> } >>>>>> >>>>>> When I go to the camel admin page (http://127.0.0.1:8161/camel), it >>>>>> shows that the route has been created. The problem is that when I try >>>>>> and send a message to the "example.A" queue, it never seems to get >>>>>> picked up by the MessageListener that is listening to the "example.B" >>>>>> queue. The sender and listener are running in separate JVM's if that >>>>>> makes a difference. >>>>>> >>>>>> Where am I going wrong? >>>>>> >>>>> >>>>> >>>> >>> >> >
