You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by nkiesel <nk...@tbdnetworks.com> on 2007/07/03 08:15:12 UTC
Unknown data type: 73 exception in
ActiveMQConnection.syncSendPacket
Hi,
I'm getting the following exception when trying to send a simple serialized
object through a persistent queue. This is with AQ 4.1.1. Any idea what I'm
doing wrong here?
Best,
Norbert
23:10:02,560 ERROR [STDERR] javax.jms.JMSException: Unknown data type: 73
23:10:02,563 ERROR [STDERR] at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:46)
23:10:02,565 ERROR [STDERR] at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1181)
23:10:02,567 ERROR [STDERR] at
org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1551)
23:10:02,569 ERROR [STDERR] at
org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:465)
23:10:02,571 ERROR [STDERR] at
org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:356)
--
View this message in context: http://www.nabble.com/Unknown-data-type%3A-73-exception-in-ActiveMQConnection.syncSendPacket-tf4016401s2354.html#a11406648
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Unknown data type: 73 exception in
ActiveMQConnection.syncSendPacket
Posted by nkiesel <nk...@tbdnetworks.com>.
Oops, forgot the stack trace
2007-07-03 10:37:10,513 ERROR [STDERR] Caused by: java.io.IOException:
Unknown data type: 73
2007-07-03 10:37:10,514 ERROR [STDERR] at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:342)
2007-07-03 10:37:10,514 ERROR [STDERR] at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:204)
2007-07-03 10:37:10,514 ERROR [STDERR] at
org.apache.activemq.store.jdbc.JDBCMessageStore$1.recoverMessage(JDBCMessageStore.java:156)
2007-07-03 10:37:10,514 ERROR [STDERR] at
org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRecover(DefaultJDBCAdapter.java:304)
2007-07-03 10:37:10,515 ERROR [STDERR] at
org.apache.activemq.store.jdbc.JDBCMessageStore.recover(JDBCMessageStore.java:154)
2007-07-03 10:37:10,515 ERROR [STDERR] at
org.apache.activemq.store.journal.JournalMessageStore.recover(JournalMessageStore.java:342)
2007-07-03 10:37:10,515 ERROR [STDERR] at
org.apache.activemq.broker.region.Queue.initialize(Queue.java:120)
2007-07-03 10:37:10,516 ERROR [STDERR] at
org.apache.activemq.broker.region.DestinationFactoryImpl.createDestination(DestinationFactoryImpl.java:95)
2007-07-03 10:37:10,516 ERROR [STDERR] at
org.apache.activemq.broker.region.AbstractRegion.createDestination(AbstractRegion.java:348)
2007-07-03 10:37:10,516 ERROR [STDERR] at
org.apache.activemq.broker.jmx.ManagedQueueRegion.createDestination(ManagedQueueRegion.java:56)
2007-07-03 10:37:10,516 ERROR [STDERR] at
org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:93)
2007-07-03 10:37:10,517 ERROR [STDERR] at
org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:254)
2007-07-03 10:37:10,517 ERROR [STDERR] at
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:142)
2007-07-03 10:37:10,517 ERROR [STDERR] at
org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:142)
2007-07-03 10:37:10,517 ERROR [STDERR] at
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:142)
2007-07-03 10:37:10,518 ERROR [STDERR] at
org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:152)
2007-07-03 10:37:10,518 ERROR [STDERR] at
org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:316)
2007-07-03 10:37:10,518 ERROR [STDERR] at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:291)
2007-07-03 10:37:10,519 ERROR [STDERR] at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:382)
2007-07-03 10:37:10,519 ERROR [STDERR] at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
2007-07-03 10:37:10,519 ERROR [STDERR] at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
2007-07-03 10:37:10,519 ERROR [STDERR] at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
2007-07-03 10:37:10,520 ERROR [STDERR] at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
2007-07-03 10:37:10,520 ERROR [STDERR] at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:498)
2007-07-03 10:37:10,520 ERROR [STDERR] at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
2007-07-03 10:37:10,521 ERROR [STDERR] at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
2007-07-03 10:37:10,521 ERROR [STDERR] at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
2007-07-03 10:37:10,521 ERROR [STDERR] at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:95)
2007-07-03 10:37:10,521 ERROR [STDERR] at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
2007-07-03 10:37:10,522 ERROR [STDERR] at
org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:96)
2007-07-03 10:37:10,522 ERROR [STDERR] at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:83)
2007-07-03 10:37:10,522 ERROR [STDERR] at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47)
2007-07-03 10:37:10,522 ERROR [STDERR] at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:69)
2007-07-03 10:37:10,523 ERROR [STDERR] at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:74)
2007-07-03 10:37:10,523 ERROR [STDERR] at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1175)
--
View this message in context: http://www.nabble.com/Unknown-data-type%3A-73-exception-in-ActiveMQConnection.syncSendPacket-tf4016401s2354.html#a11417428
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Unknown data type: 73 exception in
ActiveMQConnection.syncSendPacket
Posted by nkiesel <nk...@tbdnetworks.com>.
James.Strachan wrote:
>
> Sounds like you are communicating with an old broker; or using the
> incorrect port (e.g. talking to the stomp port or something). Maybe
> turn off the multicast discovery and double check your client jars
> match your broker jars
>
>
Hi,
I switched to the apache-activemq-4.1.1.jar, but that makes no difference. I
also deleted all files from data/journal before starting, but is still dies
in recoverMessage. Why is it even going there?
What I also noticed was that I did not post the stacktrace of the root cause
of the exception. The vm.VMTransport.oneway I see in that is also in the
stack trace for my network connector problem, but I think that's just
because both fail while trying to write, no?
The setup I'm using is as follows:
ActiveMQConnectionFactory f = new
ActiveMQConnectionFactory("vm://prim?brokerConfig=xbean:file:///opt/TBD/sync/aqprimary.xml");
Connection aqc = f.createConnection();
aqc.start();
session = aqc.createSession(false, Session.AUTO_ACKNOWLEDGE);
and /opt/TBD/sync/aqprimary.xml looks like this (notice I commented out the
network connectors for now):
<beans>
<broker brokerName="prim" xmlns="http://activemq.org/config/1.0"
useJmx="true">
<persistenceAdapter>
<journaledJDBC journalLogFiles="5" dataDirectory="/opt/TBD/sync/data"
dataSource="#oracle-ds"/>
</persistenceAdapter>
<!--networkConnectors>
<networkConnector name="secondary"
uri="static://(tcp://127.0.0.1:61618)" failover="true">
<excludedDestinations>
<queue physicalName="compile.>"/>
<queue physicalName="seccompile.>"/>
</excludedDestinations>
</networkConnector>
</networkConnectors-->
</broker>
<bean id="oracle-ds" class="oracle.jdbc.pool.OracleDataSource">
<property name="URL" value="jdbc:oracle:thin:@aaa:1521:tbddb"/>
<property name="user" value="xxx"/>
<property name="password" value="yyy"/>
</bean>
</beans>
(Just posting all of this here because I still think I'm doing something
stupidly wrong)
Best,
Norbert
--
View this message in context: http://www.nabble.com/Unknown-data-type%3A-73-exception-in-ActiveMQConnection.syncSendPacket-tf4016401s2354.html#a11417396
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Unknown data type: 73 exception in
ActiveMQConnection.syncSendPacket
Posted by nkiesel <nk...@tbdnetworks.com>.
James.Strachan wrote:
>
> Sounds like you are communicating with an old broker; or using the
> incorrect port (e.g. talking to the stomp port or something). Maybe
> turn off the multicast discovery and double check your client jars
> match your broker jars
>
> On 7/3/07, nkiesel <nk...@tbdnetworks.com> wrote:
>>
>> Hi,
>>
>> I'm getting the following exception when trying to send a simple
>> serialized
>> object through a persistent queue. This is with AQ 4.1.1. Any idea what
>> I'm
>> doing wrong here?
>>
>
Hmm, this is an internal broker (running within a jboss-4.0.4 app, but not
using any jboss integration). I'm using the jars from the lib directory
(e.g. activemq-core-4.1.1.jar) instead of the combo jar
apache-activemq-4.1.1.jar. Would that make a difference?
Background for all this is still trying to get my simple network of brokers
working (I posted another plea for help some days back). I basically have
two java servers I need to keep in sync, so I added an embedded broker to
each of them, and use a network-connector in the primary to connect to the
secondary. Then I added a layer into my server apps so that every persistent
change on the primary gets written locally and replicated to the secondary
as well.
This currently does not work at all (was working with a beta version of
4.0). So I disabled the network connector to just test my "writing into the
queue" part, and now I get this error.
I will try the combo jar and see if that makes a difference.
Thanks for your reply.
</nk>
--
View this message in context: http://www.nabble.com/Unknown-data-type%3A-73-exception-in-ActiveMQConnection.syncSendPacket-tf4016401s2354.html#a11416889
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Unknown data type: 73 exception in ActiveMQConnection.syncSendPacket
Posted by James Strachan <ja...@gmail.com>.
Sounds like you are communicating with an old broker; or using the
incorrect port (e.g. talking to the stomp port or something). Maybe
turn off the multicast discovery and double check your client jars
match your broker jars
On 7/3/07, nkiesel <nk...@tbdnetworks.com> wrote:
>
> Hi,
>
> I'm getting the following exception when trying to send a simple serialized
> object through a persistent queue. This is with AQ 4.1.1. Any idea what I'm
> doing wrong here?
>
> Best,
> Norbert
>
> 23:10:02,560 ERROR [STDERR] javax.jms.JMSException: Unknown data type: 73
> 23:10:02,563 ERROR [STDERR] at
> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:46)
> 23:10:02,565 ERROR [STDERR] at
> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1181)
> 23:10:02,567 ERROR [STDERR] at
> org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1551)
> 23:10:02,569 ERROR [STDERR] at
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:465)
> 23:10:02,571 ERROR [STDERR] at
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:356)
>
> --
> View this message in context: http://www.nabble.com/Unknown-data-type%3A-73-exception-in-ActiveMQConnection.syncSendPacket-tf4016401s2354.html#a11406648
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
James
-------
http://macstrac.blogspot.com/