So here is the setup we were trying. Run an OpenWire.NET consumer that is slow (actually a COM object exposiing the Openwire.NET basic interface to Excel) and then flood the broker with 6 java producers sending 300 messages in parallel (calling "ant producer"). This brings down the broker which refuses to respond. On the client, the error message we get is:
RECEIVED Exception: System.IO.IOException: Unknown data type: 67 at ActiveMQ.OpenWire.OpenWireFormat.LooseUnmarshalNestedObject(BinaryReader d is) at ActiveMQ.OpenWire.BaseDataStreamMarshaller.LooseUnmarshalCachedObject(Open WireFormat wireFormat, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.MessageMarshaller.LooseUnmarshal(OpenWireFormat wireF ormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.ActiveMQMessageMarshaller.LooseUnmarshal(OpenWireForm at wireFormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.ActiveMQTextMessageMarshaller.LooseUnmarshal(OpenWire Format wireFormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.OpenWireFormat.LooseUnmarshalNestedObject(BinaryReader d is) at ActiveMQ.OpenWire.BaseDataStreamMarshaller.LooseUnmarshalNestedObject(Open WireFormat wireFormat, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.MessageDispatchMarshaller.LooseUnmarshal(OpenWireForm at wireFormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.OpenWireFormat.Unmarshal(BinaryReader dis) at ActiveMQ.Transport.Tcp.TcpTransport.ReadLoop() ERROR: Transport Exception: System.IO.IOException: Unknown data type: 67 at ActiveMQ.OpenWire.OpenWireFormat.LooseUnmarshalNestedObject(BinaryReader d is) at ActiveMQ.OpenWire.BaseDataStreamMarshaller.LooseUnmarshalCachedObject(Open WireFormat wireFormat, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.MessageMarshaller.LooseUnmarshal(OpenWireFormat wireF ormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.ActiveMQMessageMarshaller.LooseUnmarshal(OpenWireForm at wireFormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.ActiveMQTextMessageMarshaller.LooseUnmarshal(OpenWire Format wireFormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.OpenWireFormat.LooseUnmarshalNestedObject(BinaryReader d is) at ActiveMQ.OpenWire.BaseDataStreamMarshaller.LooseUnmarshalNestedObject(Open WireFormat wireFormat, BinaryReader dataIn) at ActiveMQ.OpenWire.V1.MessageDispatchMarshaller.LooseUnmarshal(OpenWireForm at wireFormat, Object o, BinaryReader dataIn) at ActiveMQ.OpenWire.OpenWireFormat.Unmarshal(BinaryReader dis) at ActiveMQ.Transport.Tcp.TcpTransport.ReadLoop() On the server we get: ACTIVEMQ_HOME: I:\eqdata\denis\incubator-activemq-4.0.1\bin\.. Loading message broker from: xbean:activemq.xml INFO BrokerService - ActiveMQ 4.0.1 JMS Message Broker (localh ost) is starting INFO BrokerService - For help or more information please see: http://incubator.apache.org/activemq/ INFO JDBCPersistenceAdapter - Database driver recognized: [apache_derby _embedded_jdbc_driver] WARN JDBCPersistenceAdapter - Old message cleanup failed due to: SQL Ex ception: An SQL data change is not permitted for a read-only connection, user or database. INFO JournalPersistenceAdapter - Journal Recovery Started from: Active Jou rnal: using 5 x 20.0 Megs at: I:\eqdata\denis\incubator-activemq-4.0.1\activemq- data\journal INFO JournalPersistenceAdapter - Journal Recovered: 0 message(s) in transa ctions recovered. INFO TransportServerThreadSupport - Listening for connections at: tcp://TPC8: 61616 WARN MulticastDiscoveryAgent - brokerName not set INFO TransportConnector - Connector default Started INFO TransportServerThreadSupport - Listening for connections at: tcp://TPC8: 61613?wireFormat=stomp INFO TransportConnector - Connector stomp Started INFO NetworkConnector - Network Connector default Started INFO BrokerService - ActiveMQ JMS Message Broker (localhost, I D:TPC8-3439-1154638452030-1:0) started WARN JDBCPersistenceAdapter - Old message cleanup failed due to: SQL Ex ception: An SQL data change is not permitted for a read-only connection, user or database. WARN JDBCPersistenceAdapter - Old message cleanup failed due to: SQL Ex ception: An SQL data change is not permitted for a read-only connection, user or database. WARN JDBCPersistenceAdapter - Old message cleanup failed due to: SQL Ex ception: An SQL data change is not permitted for a read-only connection, user or database. WARN JDBCPersistenceAdapter - Old message cleanup failed due to: SQL Ex ception: An SQL data change is not permitted for a read-only connection, user or database. WARN JDBCPersistenceAdapter - Old message cleanup failed due to: SQL Ex ception: An SQL data change is not permitted for a read-only connection, user or database. -- View this message in context: http://www.nabble.com/Openwire.NET-crashes-ActiveMQ-broker-tf2048174.html#a5641106 Sent from the ActiveMQ - User forum at Nabble.com.
