activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <tim.b...@sensis.com>
Subject Re: Can ActiveMQ 4 client read from an ActiveMQ 5 server?
Date Wed, 08 Aug 2007 18:53:42 GMT
This seems to be a reoccurring theme.  I've seen the same issue with the
C++ client and so far can't find anything wrong on the client end.  Also
there was a posting the other day from someone trying to use the .Net
client with a 5.0 broker and seeing the same behavior.  

I'm still tinkering with the C++ client.  

If you find that the 5.0 client works and a 4.0 doesn't then I think we
have an issue and you should create a new Jira issue for this.

Regards 
Tim

On Wed, 2007-08-08 at 14:46 -0400, Elliotte Harold wrote:
> I have some code that worked fairly well with the release version of
> ActiveMQ 4.1 using OpenWire. One of my colleagues upgraded the server to the
> latest snapshot of ActiveMQ 5, and suddenly while I could still write to the
> queues on that server I could no longer read from them. (by the way, the new
> web interface in ActiveMQ 5 is very nice. That's what let's me see that my
> written messages are indeed arriving.
> 
> For example, this simple program to write a couple of messages and then read
> them back fails:
> 
> import javax.jms.*;
> import org.apache.activemq.*;
> import org.apache.activemq.command.*;
> 
> public class CompletedRead {
> 
> 
>     private static String url = "tcp://queue.example.com:61616";
>     private static String queue = "foo";
> 
>         public static void main(String[] args) throws JMSException {
> 
>             ConnectionFactory out = new ActiveMQConnectionFactory(url);
>             Connection connection = out.createConnection();
>             Destination destination = new ActiveMQQueue( queue );
>             connection.start();
>             Session session = connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
>             MessageProducer producer = session.createProducer(destination);
>             TextMessage message = session.createTextMessage();
>             message.setText("118652");
>             producer.send(message);
>             message.setText("118653");
>             producer.send(message);
> 
>             producer.close();
>             session.close();
>             connection.close();
> 
>             receive();
>         }
> 
>         private static void receive() throws JMSException {
>             ConnectionFactory in = new ActiveMQConnectionFactory(url);
>             Connection connection = in.createConnection();
>             Destination destination = new ActiveMQQueue( queue );
>             connection.start();
>             Session session = connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> 
>             MessageConsumer consumer = session.createConsumer(destination);
>             TextMessage message = (TextMessage) consumer.receive(10000);
>             System.out.println(message.getText());
>             message = (TextMessage) consumer.receive(10000);
>             System.out.println(message.getText());
> 
>             consumer.close();
>             session.close();
>             connection.close();
> 
>         }
> 
> 
> Should an ActiveMQ 4 client be able to read from an ActiveMQ 5 server? Or
> should it not be able to? Is this a known issue?
> 
> I'm going to try to upgrade my clients libraries to 5.0 and see what happens
> next.
> 
> 

Mime
View raw message