You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by James Strachan <ja...@gmail.com> on 2006/09/04 08:55:12 UTC

Re: mysql message size

What JDBC driver are you using and what is your XML like?

On 8/30/06, eklas <kl...@netgiro.com> wrote:
>
> This seems to happen:
>
> Caused by: java.io.IOException: Data truncation: Data too long for column
> 'MSG' at row 1
>  at
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:42)
>  at
> org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:125)
>  at
> org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessageStore.java:74)
>  at
> org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(MemoryTransactionStore.java:223)
>  at
> org.apache.activemq.store.memory.MemoryTransactionStore$1.addMessage(MemoryTransactionStore.java:116)
>  at org.apache.activemq.broker.region.Queue.send(Queue.java:253)
>  at
> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:225)
>  at
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:342)
>  at
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192)
>  at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:113)
>  at
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97)
>  at
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:126)
>  at
> org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:351)
>  at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:590)
>  at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
>  at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>  at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
>  at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
>  at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
>  at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
>  at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
>  at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
>  at java.lang.Thread.run(Thread.java:595)
> Caused by: java.lang.Throwable: java.sql.BatchUpdateException: Data
> truncation: Data too long for column 'MSG' at row 1
>  at
> com.mysql.jdbc.ServerPreparedStatement.executeBatch(ServerPreparedStatement.java:648)
>  at
> org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:205)
>  at
> org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:205)
>  at
> org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:92)
>  at
> org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:71)
>  at
> org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:107)
>
>
> Jonathan Duty-2 wrote:
> >
> > I notice that the mysql persistence uses the datatype "blob''.  What
> > happens if a message is larger than 2^16 ?
> >
>
> --
> View this message in context: http://www.nabble.com/mysql-message-size-tf693529.html#a6053536
> Sent from the ActiveMQ - User forum at Nabble.com.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Re: mysql message size

Posted by eklas <kl...@netgiro.com>.
The latest production-release driver: mysql-connector-java-3.1.13-bin.jar

XML from: http://incubator.apache.org/activemq/jdbc-support.html:
<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="url"
value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
    <property name="username" value="activemq"/>
    <property name="password" value="activemq"/>
    <property name="poolPreparedStatements" value="true"/>
</bean>



James.Strachan wrote:
> 
> What JDBC driver are you using and what is your XML like?
> 
> On 8/30/06, eklas <kl...@netgiro.com> wrote:
>>
>> This seems to happen:
>>
>> Caused by: java.io.IOException: Data truncation: Data too long for column
>> 'MSG' at row 1
>>  at
>> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:42)
>>  at
>> org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:125)
>>  at
>> org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessageStore.java:74)
>>  at
>> org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(MemoryTransactionStore.java:223)
>>  at
>> org.apache.activemq.store.memory.MemoryTransactionStore$1.addMessage(MemoryTransactionStore.java:116)
>>  at org.apache.activemq.broker.region.Queue.send(Queue.java:253)
>>  at
>> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:225)
>>  at
>> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:342)
>>  at
>> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192)
>>  at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:113)
>>  at
>> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97)
>>  at
>> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:126)
>>  at
>> org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:351)
>>  at
>> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:590)
>>  at
>> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
>>  at
>> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>>  at
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
>>  at
>> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
>>  at
>> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
>>  at
>> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
>>  at
>> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
>>  at
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
>>  at java.lang.Thread.run(Thread.java:595)
>> Caused by: java.lang.Throwable: java.sql.BatchUpdateException: Data
>> truncation: Data too long for column 'MSG' at row 1
>>  at
>> com.mysql.jdbc.ServerPreparedStatement.executeBatch(ServerPreparedStatement.java:648)
>>  at
>> org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:205)
>>  at
>> org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:205)
>>  at
>> org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:92)
>>  at
>> org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:71)
>>  at
>> org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:107)
>>
>>
>> Jonathan Duty-2 wrote:
>> >
>> > I notice that the mysql persistence uses the datatype "blob''.  What
>> > happens if a message is larger than 2^16 ?
>> >
>>
>> --
>> View this message in context:
>> http://www.nabble.com/mysql-message-size-tf693529.html#a6053536
>> Sent from the ActiveMQ - User forum at Nabble.com.
>>
>>
> 
> 
> -- 
> 
> James
> -------
> http://radio.weblogs.com/0112098/
> 
> 

-- 
View this message in context: http://www.nabble.com/mysql-message-size-tf693529.html#a6133003
Sent from the ActiveMQ - User forum at Nabble.com.