activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hasnain Muhammad Iqbal" <kama...@gmail.com>
Subject ActiveMQ - IBM Performance Harness
Date Wed, 14 Nov 2007 15:11:03 GMT
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?

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message