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.
