ActiveMQ consumer runs out of memory when messages expire

Issue

Expiring messages cause ActiveMQ consumer to throw an OutOfMemoryError.

javax.jms.JMSException: Unexpected error occured
        at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
        at org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1784)
        at org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1801)
        at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:99)
        at org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:119)
        at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:99)
        at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:99)
        at org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:160)
        at org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:248)
        at org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:96)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:194)
        at java.lang.Thread.run(Thread.java:595)
Caused by: java.io.IOException: Unexpected error occured
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:192)
        ... 1 more
Caused by: java.lang.OutOfMemoryError: Java heap space
        at org.apache.activemq.openwire.v5.BaseDataStreamMarshaller.tightUnmarshalByteSequence(BaseDataStreamMarshaller.java:440)
        at org.apache.activemq.openwire.v5.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:72)
        at org.apache.activemq.openwire.v5.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:66)
        at org.apache.activemq.openwire.v5.ActiveMQTextMessageMarshaller.tightUnmarshal(ActiveMQTextMessageMarshaller.java:66)
        at org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:459)
        at org.apache.activemq.openwire.v5.BaseDataStreamMarshaller.tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:126)
        at org.apache.activemq.openwire.v5.MessageDispatchMarshaller.tightUnmarshal(MessageDispatchMarshaller.java:71)
        at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:366)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:279)
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:210)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:202)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)