Uploaded image for project: 'ActiveMQ Classic'
  1. ActiveMQ Classic
  2. AMQ-650

Broken pipe exceptions get logged

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 4.0 M4
    • 4.0
    • Transport
    • None
    • Linux, JDK 1.5 update 6, x86-64, using ActiveMQ 4.0M4.

    Description

      I'm not sure if this is really a problem, but do these really need to be logged?

      java.net.SocketException: Broken pipe
      at java.net.SocketOutputStream.socketWrite0(Native Method)
      at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
      at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
      at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:108)
      at java.io.DataOutputStream.flush(DataOutputStream.java:106)
      at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:118)
      at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
      at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:54)
      at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:212)
      at org.apache.activemq.broker.AbstractConnection.dispatchSync(AbstractConnection.java:517)
      at org.apache.activemq.broker.AbstractConnection.dispatchAsync(AbstractConnection.java:535)
      at org.apache.activemq.broker.region.TopicSubscription.dispatch(TopicSubscription.java:142)
      at org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:54)
      at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:50)
      at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:365)
      at org.apache.activemq.broker.region.Topic.send(Topic.java:247)
      at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:195)
      at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:312)
      at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:107)
      at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97)
      at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:119)
      at org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:336)
      at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:508)
      at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:189)
      at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:60)
      at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:82)
      at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
      at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:77)
      at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
      at java.lang.Thread.run(Thread.java:595)

      Attachments

        Activity

          People

            Unassigned Unassigned
            bmitchener Bruce Mitchener
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: