activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ning Li (JIRA)" <j...@apache.org>
Subject [jira] Updated: (AMQ-750) multi-threaded issues with failover transport
Date Mon, 12 Jun 2006 21:16:51 GMT
     [ https://issues.apache.org/activemq/browse/AMQ-750?page=all ]

Ning Li updated AMQ-750:
------------------------

    Attachment: ToolSupport.java
                ProducerTool.java
                log4j.properties

Adding multi-threaded test code for the bug.

Thanks for looking into the problem.



> multi-threaded issues with failover transport
> ---------------------------------------------
>
>          Key: AMQ-750
>          URL: https://issues.apache.org/activemq/browse/AMQ-750
>      Project: ActiveMQ
>         Type: Bug

>   Components: Transport
>     Versions: 4.0
>  Environment: Got the June 6 code using svn, and test is run on Windows
>     Reporter: Ning Li
>     Priority: Minor
>  Attachments: ProducerTool.java, ToolSupport.java, log4j.properties
>
>
> Modified ProducerTool.java into multi-threaded test code:
> This is the peudo code:
> For ( thread 1 to 30 ) 
> { 
>     Connection connection = createConnection(); 
>     Session session = createSession(connection); 
>    Producer producer = createProducer(session); 
>    sendMessages(producer, 10); //each thread send 10 messages to broker, using url =
failover:tcp://localhost:61616
> } 
> Please turn on Debug info for log4j, otherwise you will hit other threading issue before
this one, when client shutting down, this exception will be thrown:
> Thread-13 Sending total message: 10 Total time: 203 DONE !!!
> [                     Thread-13] FailoverTransport              DEBUG Stopped.
> [cp://localhost/127.0.0.1:61616] FailoverTransport              DEBUG Transport failed,
starting up reconnect task
> java.net.SocketException: socket closed
> 	at java.net.SocketInputStream.socketRead0(Native Method)
> 	at java.net.SocketInputStream.read(SocketInputStream.java:129)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
> 	at java.io.DataInputStream.readInt(DataInputStream.java:353)
> 	at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
> 	at java.lang.Thread.run(Thread.java:595)
> [            ActiveMQ Scheduler] InactivityMonitor              DEBUG Message sent since
last write check, resetting flag
> [cp://localhost/127.0.0.1:61616] FailoverTransport              DEBUG Transport failed,
starting up reconnect task
> java.net.SocketException: Connection reset
> 	at java.net.SocketInputStream.read(SocketInputStream.java:168)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
> 	at java.io.DataInputStream.readInt(DataInputStream.java:353)
> 	at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
> 	at java.lang.Thread.run(Thread.java:595)
> [                 ActiveMQ Task] FailoverTransport              DEBUG Attempting connect
to: tcp://localhost:61616
> Thread-17 Sending total message: 10 Total time: 109 DONE !!!
> [                     Thread-17] FailoverTransport              DEBUG Stopped.
> [cp://localhost/127.0.0.1:61616] FailoverTransport              DEBUG Transport failed,
starting up reconnect task
> java.net.SocketException: socket closed
> 	at java.net.SocketInputStream.socketRead0(Native Method)
> 	at java.net.SocketInputStream.read(SocketInputStream.java:129)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
> 	at java.io.DataInputStream.readInt(DataInputStream.java:353)
> 	at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
> 	at java.lang.Thread.run(Thread.java:595)
> Thread-14 Sending total message: 10 Total time: 328 DONE !!!
> [cp://localhost/127.0.0.1:61616] FailoverTransport              DEBUG Transport failed,
starting up reconnect task
> java.net.SocketException: socket closed
> 	at java.net.SocketInputStream.socketRead0(Native Method)
> 	at java.net.SocketInputStream.read(SocketInputStream.java:129)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
> 	at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
> 	at java.io.DataInputStream.readInt(DataInputStream.java:353)
> 	at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
> 	at java.lang.Thread.run(Thread.java:595)

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
   https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see:
   http://www.atlassian.com/software/jira


Mime
View raw message