FUSE Message Broker
  1. FUSE Message Broker
  2. MB-944

NullpointerException when trying to addMessage to FilePendingCursor

    Details

    • Type: Bug Bug
    • Status: Open Open
    • Priority: Major Major
    • Resolution: Unresolved
    • Affects Version/s: 5.5.0-fuse-00-00
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None
    • Similar Issues:
      Show 10 results 

      Description

      This occurs in apache-activemq-5.5-fuse-20110805.150151-38, user can oonly provide execption

      2011-08-15 11:08:11,529 [38.252.80:50770] ERROR FilePendingMessageCursor - Caught an Exception adding a message: ActiveMQTextMessage {commandId = 107930, responseRequired = false, messageId = ID:gridmsg005.cern.ch-44319-1313138733399-2:4787:-1:1:107928, originalDestination = null, originalTransactionId = null, producerId = ID:gridmsg005.cern.ch-44319-1313138733399-2:4787:-1:1, destination = queue://test_gro2, transactionId = null, expiration = 1313658491526, timestamp = 1313399291526, arrival = 0, brokerInTime = 1313399291526, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@629ad55, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 3250, properties = null, readOnlyProperties = true, readOnlyBody = true, droppable = false, text =

      { "t_id":"194029963xfc", "afqn... }

      } first to FilePendingMessageCursor
      java.lang.NullPointerException
      at java.lang.System.arraycopy(Native Method)
      at org.apache.activemq.util.DataByteArrayOutputStream.write(DataByteArrayOutputStream.java:107)
      at org.apache.activemq.openwire.v6.BaseDataStreamMarshaller.looseMarshalByteSequence(BaseDataStreamMarshaller.java:631)
      at org.apache.activemq.openwire.v6.MessageMarshaller.looseMarshal(MessageMarshaller.java:295)
      at org.apache.activemq.openwire.v6.ActiveMQMessageMarshaller.looseMarshal(ActiveMQMessageMarshaller.java:111)
      at org.apache.activemq.openwire.v6.ActiveMQTextMessageMarshaller.looseMarshal(ActiveMQTextMessageMarshaller.java:111)
      at org.apache.activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:168)
      at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.getByteSequence(FilePendingMessageCursor.java:477)
      at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:225)
      at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.addMessageLast(FilePendingMessageCursor.java:196)
      at org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:1608)
      at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:714)
      at org.apache.activemq.broker.region.Queue.send(Queue.java:646)
      at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:379)
      at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:542)
      at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:300)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
      at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:306)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.broker.UserIDBroker.send(UserIDBroker.java:56)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.plugin.RestrictionBroker.send(RestrictionBroker.java:82)
      at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
      at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:468)
      at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681)
      at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:316)
      at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
      at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
      at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:81)
      at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:140)
      at org.apache.activemq.transport.stomp.ProtocolConverter.onStompSend(ProtocolConverter.java:257)
      at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:178)
      at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:70)
      at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
      at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:223)
      at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:205)
      at java.lang.Thread.run(Thread.java:619)
      2011-08-15 11:08:11,539 [38.252.80:50770] WARN Service - Async error occurred: java.lang.RuntimeException: java.lang.NullPointerException
      java.lang.RuntimeException: java.lang.NullPointerException
      at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:233)
      at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.addMessageLast(FilePendingMessageCursor.java:196)
      at org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:1608)
      at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:714)
      at org.apache.activemq.broker.region.Queue.send(Queue.java:646)
      at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:379)
      at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:542)
      at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:300)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
      at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:306)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.broker.UserIDBroker.send(UserIDBroker.java:56)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
      at org.apache.activemq.plugin.RestrictionBroker.send(RestrictionBroker.java:82)
      at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
      at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:468)
      at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681)
      at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:316)
      at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
      at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
      at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:81)
      at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:140)
      at org.apache.activemq.transport.stomp.ProtocolConverter.onStompSend(ProtocolConverter.java:257)
      at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:178)
      at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:70)
      at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
      at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:223)
      at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:205)
      at java.lang.Thread.run(Thread.java:619)
      Caused by: java.lang.NullPointerException
      at java.lang.System.arraycopy(Native Method)
      at org.apache.activemq.util.DataByteArrayOutputStream.write(DataByteArrayOutputStream.java:107)
      at org.apache.activemq.openwire.v6.BaseDataStreamMarshaller.looseMarshalByteSequence(BaseDataStreamMarshaller.java:631)
      at org.apache.activemq.openwire.v6.MessageMarshaller.looseMarshal(MessageMarshaller.java:295)
      at org.apache.activemq.openwire.v6.ActiveMQMessageMarshaller.looseMarshal(ActiveMQMessageMarshaller.java:111)
      at org.apache.activemq.openwire.v6.ActiveMQTextMessageMarshaller.looseMarshal(ActiveMQTextMessageMarshaller.java:111)
      at org.apache.activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:168)
      at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.getByteSequence(FilePendingMessageCursor.java:477)
      at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:225)
      ... 30 more
      2011-08-15 11:08:11,548 [38.252.80:50770] WARN ProtocolConverter - Exception occurred processing:
      null: java.lang.RuntimeException: java.lang.NullPointerException

        Activity

        Hide
        Gary Tully
        added a comment -

        lets see if we can get this resolved for the next 5.5.x release.

        Show
        Gary Tully
        added a comment - lets see if we can get this resolved for the next 5.5.x release.
        Hide
        Gary Tully
        added a comment -

        we need to get some more information on this one, I currently cannot find any code path that would lead to this (at least not on trunk).

        Show
        Gary Tully
        added a comment - we need to get some more information on this one, I currently cannot find any code path that would lead to this (at least not on trunk).
        Hide
        Gary Tully
        added a comment -

        parking this one pending some new information

        Show
        Gary Tully
        added a comment - parking this one pending some new information

          People

          • Assignee:
            Unassigned
            Reporter:
            Sean O'Callaghan
          • Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

            • Created:
              Updated: