activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rob Davies (JIRA)" <j...@apache.org>
Subject [jira] Resolved: (AMQ-750) multi-threaded issues with failover transport
Date Mon, 30 Jul 2007 11:43:53 GMT

     [ https://issues.apache.org/activemq/browse/AMQ-750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Rob Davies resolved AMQ-750.
----------------------------

       Resolution: Fixed
    Fix Version/s: 5.0.0

> multi-threaded issues with failover transport
> ---------------------------------------------
>
>                 Key: AMQ-750
>                 URL: https://issues.apache.org/activemq/browse/AMQ-750
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Transport
>    Affects Versions: 4.0
>         Environment: Got the June 6 code using svn, and test is run on Windows
>            Reporter: Ning Li
>            Assignee: Rob Davies
>            Priority: Minor
>             Fix For: 5.0.0
>
>         Attachments: log4j.properties, ProducerTool.java, ToolSupport.java
>
>
> 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.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message