This is a known bug in 5.0 - please try the 5.1 release candidate - http://people.apache.org/~chirino/staging-repos/activemq-5.1.0-RC6/org/apache/activemq/apache-activemq/5.1.0/

cheers,

Rob

On 5 May 2008, at 15:48, DavidS4 wrote:

>
> I am developing a notification system that writes to ActiveMQ.  It  
> seems to
> work great, for a while.  I pushed about 250,000 messages to the  
> topic,
> reading them on the subscriber all the while.  We then stopped  
> generating
> the messages.  When we started again, I got the following error:
>
> javax.jms.JMSException: java.lang.RuntimeException:
> org.apache.activemq.kaha.RuntimeStoreException: java.io.IOException:  
> Could
> not locate data file data-topic-data-1
>
> What does this mean?  What caused it?  I also noticed a very large  
> number of
> open sockets from my producer machine to my ActiveMQ queue machine.   
> Would
> this be related?  I had assumed that a single socket would exist  
> between
> them, but this was not the case.  If it helps, here is the code I am  
> using:
>
> 	/**
> 	 * Send an event to the local singleton instance
> 	 *
> 	 * @param event event to send to the topic
> 	 * @throws JMSException
> 	 */
> 	private void sendEventNotification(JMSNotificationEvent event)
> 	{
> 		try
> 		{
> 			TextMessage message = session.createTextMessage(event.toString());
> 			producer.send(message);
> 		}
> 		catch (JMSException jmsx)
> 		{
> 			// we catch the first one in case the JMS server was brought down  
> then
> back up
> 			logger.debug("JMSTopicManager: Send failed, refreshing JMS  
> connection.
> Error was: " + jmsx);
> 			try
> 			{
> 			    refreshJMSConnection();
> 			    TextMessage message =  
> session.createTextMessage(event.toString());
>
> 				producer.send(message);
> 				this.increment(event);
> 			}
> 			catch (JMSException jmsx2)
> 			{
> 				logger.error("JMSTopicManager: " + jmsx2);
> 			}
> 		}
> 		catch (Exception err)
> 		{
> 			logger.error("JMSTopicManager: " + err);
> 		}
> 	}
>
> And
>
> 	private void refreshJMSConnection() throws JMSException
> 	{
> 		ActiveMQConnectionFactory connectionFactory = new
> ActiveMQConnectionFactory(user, passwd, url);
> 		connection = connectionFactory.createConnection();
> 		connection.start();
>
> 		// Create the session
> 		session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
> 		destination = session.createTopic(JMSTopicManager.TOPIC_SUBJECT);
>
> 		// Create the producer.
> 		producer = session.createProducer(destination);
> 		producer.setDeliveryMode(DeliveryMode.PERSISTENT);
> 		if ( timeToLive > 0 )
> 		{
> 			producer.setTimeToLive(timeToLive);
> 		}
> 		
> 		// set to true to indicate that the connection was established
> successfully
> 	    initialized = true;
> 	}
> -- 
> View this message in context: http://www.nabble.com/ActiveMQ-5.0.0-----Could-not-locate-data-file-data-topic-data-1-tp17063347s2354p17063347.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>