activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yolcuabbas <mehmet.ber...@gmail.com>
Subject Re: ActiveMQ - IBM Performance Harness
Date Wed, 14 Nov 2007 20:53:57 GMT

Hi,

if you create a JMS Message with CorrellationID ( byte [] x = new byte
[]{0,0,0} ), then you receive such exceptions. I dont know whether it is a
bug or a feature ...




Hasnain Muhammad Iqbal wrote:
> 
> Hi,
> 
> I am running IBM Performance Harness with ActiveMQ 4.1.1 and it is giving
> me
> bad string error (Caused by: java.io.UTFDataFormatException: bad string)
> when it is unmashalling the data on correlationId  ... the database is
> Derby
> and i am using jdbcPersistance adapter for persistence. Can someone pls
> telling why this is happening.
> 
> O.S = Ubuntu
> version=4.1.1 (ActiveMQ)
> IBM Performance Harness address:
> http://www.alphaworks.ibm.com/tech/perfharness
> 
> *
> The command that i ran for testing is:*
> 
> java -cp ./apache-activemq-4.1.1.jar:./perfharness.jar JMSPerfHarness -tc
> jms.r11.PutGet -nt 1 -pp -tx -pc JNDI -ii
> org.apache.activemq.jndi.ActiveMQInitialContextFactory -iu
> tcp://localhost:61616 -cf ConnectionFactory -d dynamicQueues/myqueue -rl
> 20
> -mu true -rt 100 -mf message.txt
> 
> *ActiveMQ configuration:*
> 
> <beans>
> 
>   <!-- Allows us to use system properties as variables in this
> configuration
> file -->
>   <bean class="
> org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
> 
>   <broker brokerName="localhost" useJmx="true" xmlns="
> http://activemq.org/config/1.0">
> 
>     <!-- In ActiveMQ 4, you can setup destination policies -->
>     <destinationPolicy>
>       <policyMap><policyEntries>
> 
>           <policyEntry topic="FOO.>">
>             <dispatchPolicy>
>               <strictOrderDispatchPolicy />
>             </dispatchPolicy>
>             <subscriptionRecoveryPolicy>
>               <lastImageSubscriptionRecoveryPolicy />
>             </subscriptionRecoveryPolicy>
>           </policyEntry>
> 
>       </policyEntries></policyMap>
>     </destinationPolicy>
> 
> 
>     <persistenceAdapter>
>       <jdbcPersistenceAdapter  dataSource="#derby-ds"/>
>     </persistenceAdapter>
> 
>     <transportConnectors>
>        <transportConnector name="openwire" uri="tcp://localhost:61616"
> discoveryUri="multicast://default"/>
>        <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
>        <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
>     </transportConnectors>
> 
>     <networkConnectors>
>       <networkConnector name="default-nc" uri="multicast://default"/>
>     </networkConnectors>
> 
>   </broker>
>   <!-- Embedded Derby DataSource Sample Setup -->
>   <bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
>     <property name="databaseName" value="derbydb"/>
>     <property name="createDatabase" value="create"/>
>   </bean>
> 
> </beans>
> 
> 
> *Error:*
> java.lang.RuntimeException: java.io.IOException: Failed to broker message:
> ID:StarDust-47427-1195051460634-1:0:1:1:1 in container:
> java.io.UTFDataFormatException: bad string
>         at
> org.apache.activemq.broker.region.IndirectMessageReference.incrementReferenceCount
> (IndirectMessageReference.java:103)
>         at org.apache.activemq.filter.MessageEvaluationContext.getMessage(
> MessageEvaluationContext.java:55)
>         at org.apache.activemq.filter.MessageEvaluationContext.isDropped(
> MessageEvaluationContext.java:48)
>         at org.apache.activemq.filter.PropertyExpression.evaluate(
> PropertyExpression.java:152)
>         at org.apache.activemq.filter.ComparisonExpression$1.evaluate(
> ComparisonExpression.java:197)
>         at org.apache.activemq.filter.ComparisonExpression.matches(
> ComparisonExpression.java:455)
>         at org.apache.activemq.broker.region.AbstractSubscription.matches(
> AbstractSubscription.java:92)
>         at
> org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy.dispatch(
> RoundRobinDispatchPolicy.java:52)
>         at
> org.apache.activemq.broker.region.Queue.dispatch(Queue.java:520)
>         at
> org.apache.activemq.broker.region.Queue.access$600(Queue.java:75)
>         at
> org.apache.activemq.broker.region.Queue$3.afterCommit(Queue.java
> :341)
>         at org.apache.activemq.transaction.Transaction.fireAfterCommit(
> Transaction.java:83)
>         at org.apache.activemq.transaction.LocalTransaction.commit(
> LocalTransaction.java:71)
>         at org.apache.activemq.broker.TransactionBroker.commitTransaction(
> TransactionBroker.java:154)
>         at org.apache.activemq.broker.BrokerFilter.commitTransaction(
> BrokerFilter.java:94)
>         at org.apache.activemq.broker.BrokerFilter.commitTransaction(
> BrokerFilter.java:94)
>         at
> org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(
> MutableBrokerFilter.java:104)
>         at
> org.apache.activemq.broker.TransportConnection.processCommitTransactionOnePhase
> (TransportConnection.java:424)
>         at org.apache.activemq.command.TransactionInfo.visit(
> TransactionInfo.java:99)
>         at org.apache.activemq.broker.TransportConnection.service(
> TransportConnection.java:294)
>         at org.apache.activemq.broker.TransportConnection$1.onCommand(
> TransportConnection.java:185)
>         at org.apache.activemq.transport.TransportFilter.onCommand(
> TransportFilter.java:65)
>         at org.apache.activemq.transport.WireFormatNegotiator.onCommand(
> WireFormatNegotiator.java:133)
>         at org.apache.activemq.transport.InactivityMonitor.onCommand(
> InactivityMonitor.java:122)
>         at org.apache.activemq.transport.TransportSupport.doConsume(
> TransportSupport.java:84)
>         at org.apache.activemq.transport.tcp.TcpTransport.run(
> TcpTransport.java:137)
>         at java.lang.Thread.run(Thread.java:619)
> Caused by: java.io.IOException: Failed to broker message:
> ID:StarDust-47427-1195051460634-1:0:1:1:1 in container:
> java.io.UTFDataFormatException: bad string
>         at org.apache.activemq.util.IOExceptionSupport.create(
> IOExceptionSupport.java:31)
>         at org.apache.activemq.store.jdbc.JDBCMessageStore.getMessage(
> JDBCMessageStore.java:107)
>         at org.apache.activemq.store.ProxyMessageStore.getMessage(
> ProxyMessageStore.java:48)
>         at
> org.apache.activemq.broker.region.IndirectMessageReference.incrementReferenceCount
> (IndirectMessageReference.java:95)
>         ... 26 more
> Caused by: java.io.UTFDataFormatException: bad string
>         at org.apache.activemq.util.DataByteArrayInputStream.readUTF(
> DataByteArrayInputStream.java:277)
>         at
> org.apache.activemq.openwire.v2.BaseDataStreamMarshaller.looseUnmarshalString
> (BaseDataStreamMarshaller.java:536)
>         at
> org.apache.activemq.openwire.v2.MessageMarshaller.looseUnmarshal(
> MessageMarshaller.java:201)
>         at
> org.apache.activemq.openwire.v2.ActiveMQMessageMarshaller.looseUnmarshal(
> ActiveMQMessageMarshaller.java:101)
>         at
> org.apache.activemq.openwire.v2.ActiveMQTextMessageMarshaller.looseUnmarshal
> (ActiveMQTextMessageMarshaller.java:101)
>         at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(
> OpenWireFormat.java:349)
>         at org.apache.activemq.openwire.OpenWireFormat.unmarshal(
> OpenWireFormat.java:204)
>         at org.apache.activemq.store.jdbc.JDBCMessageStore.getMessage(
> JDBCMessageStore.java:104)
>         ... 28 more
> 
> 
> -- 
> Regards,
> Hasnain M Iqbal
> M.Sc Software Engineering in Distributed System
> KTH - Royal Institute of Technology
> 
> For what shall it profit a man, if he shall gain the whole world, and lose
> his own soul?
> 
> 

-- 
View this message in context: http://www.nabble.com/ActiveMQ---IBM-Performance-Harness-tf4806005s2354.html#a13756227
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message