activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From JMRAustin <aus...@jmr.ca>
Subject JMS Message Producer runs continuosly
Date Thu, 06 Nov 2008 20:58:36 GMT

Using ActiveMQ 5.1.0 or 5.2.0 RC3.

My JMS Message Producer runs continuosly.  The messages are sent and then
the program just hangs.

Here is the code I am using:

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.log4j.*;
import org.apache.log4j.net.*;

import javax.jms.*;

public final class SimpleProducerFromFile {

	// Initializing the logger
	private static final Logger logger =
Logger.getLogger(SimpleProducerFromFile.class);

	/**
	 * A JMS Message producer using log4j. jms-1.1.jar(OpenJMS),
	 * log4j-1.2.11.jar and activemq-all-5.1.0.jar should be included in the
	 * class path. Sends to an ip and topic based on the constants above.
	 * 
	 */

	public static void main(String[] args2) {

		
		PropertyConfigurator.configure("C:\\log4j\\Config.txt");
		logger.error("An error");

		
		System.out.println("done");
	}
}


Here is the config file:


log4j.logger.SimpleProducerFromFile=DEBUG, jms
log4j.appender.jms=org.apache.log4j.net.JMSAppender
log4j.appender.jms.InitialContextFactoryName=org.apache.activemq.jndi.ActiveMQInitialContextFactory
log4j.appender.jms.ProviderURL=tcp://192.168.0.102:61616
log4j.appender.jms.TopicConnectionFactoryBindingName=TopicConnectionFactory
log4j.appender.jms.TopicBindingName=dynamicTopics/Topic


Here is a Java thread dump from the program while it is still hanging:

2008-10-27 14:41:52
Full thread dump Java HotSpot(TM) Client VM (10.0-b23 mixed mode, sharing):

"DestroyJavaVM" prio=6 tid=0x00395c00 nid=0xce4 waiting on condition
[0x00000000..0x003ffd4c]
   java.lang.Thread.State: RUNNABLE

"InactivityMonitor WriteCheck" daemon prio=6 tid=0x02df7c00 nid=0x5c0 in
Object.wait() [0x031bf000..0x031bfb14]
   java.lang.Thread.State: TIMED_WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	- waiting on <0x22fa8b40> (a java.util.TaskQueue)
	at java.util.TimerThread.mainLoop(Unknown Source)
	- locked <0x22fa8b40> (a java.util.TaskQueue)
	at java.util.TimerThread.run(Unknown Source)

"InactivityMonitor ReadCheck" daemon prio=6 tid=0x02de3c00 nid=0x710 in
Object.wait() [0x0316f000..0x0316fa94]
   java.lang.Thread.State: TIMED_WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	- waiting on <0x22fa8bf0> (a java.util.TaskQueue)
	at java.util.TimerThread.mainLoop(Unknown Source)
	- locked <0x22fa8bf0> (a java.util.TaskQueue)
	at java.util.TimerThread.run(Unknown Source)

"ActiveMQ Transport: tcp:///192.168.0.102:61616" prio=6 tid=0x02df0800
nid=0x290 runnable [0x0311f000..0x0311fb94]
   java.lang.Thread.State: RUNNABLE
	at java.net.SocketInputStream.socketRead0(Native Method)
	at java.net.SocketInputStream.read(Unknown Source)
	at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
	at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
	at java.io.DataInputStream.readInt(Unknown Source)
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
	at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:203)
	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:195)
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)
	at java.lang.Thread.run(Unknown Source)

"Low Memory Detector" daemon prio=6 tid=0x02a66000 nid=0xc44 runnable
[0x00000000..0x00000000]
   java.lang.Thread.State: RUNNABLE

"CompilerThread0" daemon prio=10 tid=0x02a58400 nid=0xf18 waiting on
condition [0x00000000..0x02d0f640]
   java.lang.Thread.State: RUNNABLE

"Attach Listener" daemon prio=10 tid=0x02a57000 nid=0x840 waiting on
condition [0x00000000..0x00000000]
   java.lang.Thread.State: RUNNABLE

"Signal Dispatcher" daemon prio=10 tid=0x02a56400 nid=0xf0 runnable
[0x00000000..0x00000000]
   java.lang.Thread.State: RUNNABLE

"Finalizer" daemon prio=8 tid=0x02a4e400 nid=0x524 in Object.wait()
[0x02c1f000..0x02c1fa94]
   java.lang.Thread.State: WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	- waiting on <0x22f687c8> (a java.lang.ref.ReferenceQueue$Lock)
	at java.lang.ref.ReferenceQueue.remove(Unknown Source)
	- locked <0x22f687c8> (a java.lang.ref.ReferenceQueue$Lock)
	at java.lang.ref.ReferenceQueue.remove(Unknown Source)
	at java.lang.ref.Finalizer$FinalizerThread.run(Unknown Source)

"Reference Handler" daemon prio=10 tid=0x02a4d400 nid=0xba0 in Object.wait()
[0x02bcf000..0x02bcfb14]
   java.lang.Thread.State: WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	- waiting on <0x22f68850> (a java.lang.ref.Reference$Lock)
	at java.lang.Object.wait(Object.java:485)
	at java.lang.ref.Reference$ReferenceHandler.run(Unknown Source)
	- locked <0x22f68850> (a java.lang.ref.Reference$Lock)

"VM Thread" prio=10 tid=0x02a4c400 nid=0x7c0 runnable 

"VM Periodic Task Thread" prio=10 tid=0x02a79400 nid=0xad8 waiting on
condition 

JNI global references: 914


Any assistance would be appreciated.

Thanks,

Austin



-- 
View this message in context: http://www.nabble.com/JMS-Message-Producer-runs-continuosly-tp20369525p20369525.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message