Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-users@geronimo.apache.org
Received-SPF: pass (asf.osuosl.org: domain of lists@nabble.com designates
 72.21.53.35 as permitted sender)
Message-ID: <5641106.post@talk.nabble.com>
Date: Thu, 3 Aug 2006 14:29:25 -0700 (PDT)
From: sparky2708 <daa82@columbia.edu>
To: activemq-users@geronimo.apache.org
Subject: Openwire.NET crashes ActiveMQ broker
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


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.