I'm having trouble interpreting this post, and the linked bug. Has this been fixed in the OpenWire .NET client? If so, how do I get the fix? I'm using the OpenWire .NET client code I downloaded from here:
svn co http://svn.apache.org/repos/asf/incubator/activemq/trunk/activemq-dotnet/ And what I believe is ActiveMQ 4.0.1. I run the consumer example, and get the following output: C:\Documents and Settings\dclark\Desktop\My Stuff\tools\ActiveMQ\incubator-activemq-4.0.1\example>ant consumer Buildfile: build.xml init: compile: consumer: [echo] Running consumer against server at $url = tcp://localhost:61616 for subject $subject = TEST.FOO [java] Connecting to URL: tcp://localhost:61616 [java] Consuming queue: TEST.FOO [java] Using non-durable subscription [java] We are about to wait until we consume: 10 message(s) then we will shutdown [java] ---- well, we got this far... ---- [java] ---- message.toString: ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId = ae38d0ea-6db a-4488-80b1-8cbd9f383fe6:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ae38d0ea-6dba-448 8-80b1-8cbd9f383fe6:1:1, destination = queue://TEST.FOO, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, correlationId = abc, replyTo = null, persistent = false, type = null, priority = 0, groupID = null, groupSequence = 0 , targetConsumerId = null, compressed = false, userID = null, content = [EMAIL PROTECTED], marshalledProperties = [EMAIL PROTECTED], dataStructure = null, redeliveryCounter = 1, si ze = 0, properties = null, readOnlyProperties = true, readOnlyBody = true, text = null} [java] Exception in thread "main" java.lang.OutOfMemoryError: Requested array size exceeds VM limit [java] ---- casting message to TextMessage message My client app does this: private void button1_Click(object sender, EventArgs e) { IConnectionFactory factory = new ConnectionFactory(new Uri(hosttextBox.Text)); using (IConnection connection = factory.CreateConnection()) { ISession session = connection.CreateSession(); IDestination destination = session.GetQueue(queuetextBox.Text); // lets create a producer IMessageProducer producer = session.CreateProducer(destination); producer.Persistent = true; // lets send a message ITextMessage request = session.CreateTextMessage("Hello World!"); request.NMSCorrelationID = "abc"; request.Properties["JMSXGroupID"] = "cheese"; request.Properties["myHeader"] = "James"; producer.Send(request); } } Am I doing something wrong, or is this still a bug? JIRA [EMAIL PROTECTED] wrote: > > Text message format is incompatible between activemq and openwire .NET > ---------------------------------------------------------------------- > > Key: AMQ-659 > URL: http://jira.activemq.org/jira//browse/AMQ-659 > Project: ActiveMQ > Type: Bug > > Components: Broker > Versions: 4.0 > Environment: - ActiveMQ Snapshot from 06-April > - Openwire .NET revision 392254 (Used on framework 1.1) > - Solaris 10 for activemq broker > Reporter: Laurent Jeanneau > > > The class MarshallingSupport (from org.apache.activemq.util) is > unmarshalling / marshalling UTF8 strings containing the length coded as an > integer at the beginning of the stream. > > Unfortunately the strings marshalled by openwire do not contain any length > at the beginning. Decoding these strings result in a > java.lang.OutOfMemoryError: Java heap space in activemq (the first 4 bytes > of the string are interpreted as a length resulting in a buffer overflow) > > -- > This message is automatically generated by JIRA. > - > If you think it was sent incorrectly contact one of the administrators: > http://jira.activemq.org/jira//secure/Administrators.jspa > - > For more information on JIRA, see: > http://www.atlassian.com/software/jira > > > -- View this message in context: http://www.nabble.com/-jira--Created%3A-%28AMQ-659%29-Text-message-format-is-incompatible-between-activemq-and-openwire-.NET-tf1412109.html#a5875223 Sent from the ActiveMQ - Dev forum at Nabble.com.
