activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kirkal <biki...@gmail.com>
Subject Re: transport connector problem
Date Tue, 27 Jun 2006 09:45:02 GMT

hi

 thanks for the reply....

 i think its part of a larger problem - i have AMQ 4.0 RC2 up and running on
a system(remotehost) and am trying to send messages to a topic and receive
messages from the topic using a simple pub/sub code beofre i proceed to
anything further. however, the topicconsume code keeps returning a
"Received:null " as the result. what do i do?  the code fragments are as
shown below:

TopicPublish.java

Context ctx = new InitialContext();
			ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("tcp://remotehost:61616");
            Connection connection = connectionFactory.createConnection();
            connection.start();
			TopicSession topicSession = ((TopicConnection)
connection).createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
Topic destination = topicSession.createTopic("TEST.FOO");
TopicPublisher topicPublisher = topicSession.createPublisher(destination);
System.out.println("Sample application publishing a message to a topic.");
			for ( int i=0;i<10;i++)
			{
				
			
			TextMessage message = topicSession.createTextMessage("Hello world");
			message.setJMSDestination(destination);
			topicPublisher.publish(message);
			topicPublisher.publish(destination,message);
			topicPublisher.send(destination,message);
			System.out.println(topicPublisher.getDestination());
			System.out.println(message);
			topicPublisher.publish(destination,message);
}
			// clean up
			topicPublisher.close();
			topicSession.close();
			connection.close();
			
		}




TopicConsume.java

Same setup as before

Topic destination = topicSession.createTopic("TEST.FOO"); 		

			MessageConsumer consumer =
topicSession.createDurableSubscriber(destination, null);
			
			Message message = consumer.receive(1000);

            if (message instanceof TextMessage) {
                TextMessage textMessage = (TextMessage) message;
                String text = textMessage.getText();
                System.out.println("Received: " + text);
            } else {
                System.out.println("Received: " + message);
            }




  By rights, this is such simple code that it should run with no
problems......it does not run, at all. 

  Eitehr the TopicConsume code crashes saying the host is unreachable or
Reason: java.net.NoRouteToHostException: No route to host

  I have no clue whaat to do here....even simple code like this seems not to
work and i seem to find no documentation that helps.

 any help / suggestions would be appreciated.
-- 
View this message in context: http://www.nabble.com/transport-connector-problem-tf1847502.html#a5062872
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message