You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Rob Godfrey (JIRA)" <ji...@apache.org> on 2015/06/13 11:28:00 UTC
[jira] [Comment Edited] (QPID-6587) Qpid crash when trying to
convert a message
[ https://issues.apache.org/jira/browse/QPID-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14584512#comment-14584512 ]
Rob Godfrey edited comment on QPID-6587 at 6/13/15 9:27 AM:
------------------------------------------------------------
I have committed a fix which should be available in the next release of the Java Broker. In the meantime messages which have an sort of application property set should convert fine... So changing to something like
{code}
TextMessage message = session.createTextMessage("Hello world from Java " + i + " !");
message.setStringProperty("test","test");
Thread.sleep(1000L);
producer.send(message, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE); }
{code}
should work.
was (Author: rgodfrey):
I have committed a fix which should be available in the next release of the Java Broker. In the meantime messages which have an sort of application property set should convert fine... So changing to something like
{code}
TextMessage message = session.createTextMessage("Hello world from Java " + i + " !");
message.setStringProperty("test");
Thread.sleep(1000L);
producer.send(message, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE); }
{code}
should work.
> Qpid crash when trying to convert a message
> -------------------------------------------
>
> Key: QPID-6587
> URL: https://issues.apache.org/jira/browse/QPID-6587
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker
> Affects Versions: 0.32
> Environment: Linux localhost 3.17.8-gentoo-r1 #6 SMP Sat May 16 15:11:24 GST 2015 x86_64 Intel(R) Core(TM) i5-2540M CPU @ 2.60GHz GenuineIntel GNU/Linux
> Reporter: Mansour Al Akeel
> Assignee: Rob Godfrey
> Priority: Blocker
> Labels: broker, convert, message, qpid
> Fix For: 6.0 [Java]
>
>
> Related Issues: QPID-5536
> This issue may be related to converting message format.
> To generate this problem, create a new port (ie AMQP_0_10) and give it ampq_0-10, assign it another port number (for example 5673).
> Setup the security provider to Anonymous (create a provider for this).
> Create a queue "examples".
> Send few messages to "examples" to AMQP port.
> Try to read from AMQP_0_10.
> The broker will crash end exit.
> In my case, the writing was done from Java, and reading from Python.
> These code can be used:
> For maven:
> <dependency>
> <groupId>org.apache.qpid</groupId>
> <artifactId>qpid-jms-client</artifactId>
> <version>0.2.0</version>
> </dependency>
> import java.util.Properties;
> import javax.jms.Connection;
> import javax.jms.ConnectionFactory;
> import javax.jms.DeliveryMode;
> import javax.jms.Destination;
> import javax.jms.ExceptionListener;
> import javax.jms.JMSException;
> import javax.jms.Message;
> import javax.jms.MessageProducer;
> import javax.jms.Session;
> import javax.jms.TextMessage;
> import javax.naming.Context;
> import javax.naming.InitialContext;
> public class Hello
> {
> private static final String USER = "guest";
> private static final String PASSWORD = "guest";
> public static void main(String[] args)
> {
> try
> {
> Properties prop = new Properties();
> prop.put("java.naming.factory.initial", "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
> prop.put("connectionfactory.localhost", "amqp://localhost:5672/");
> prop.put("queue.myQueue", "examples");
> Context context = new InitialContext(prop);
> ConnectionFactory factory = (ConnectionFactory) context.lookup("localhost");
> Destination queue = (Destination) context.lookup("myQueue");
> Connection connection = factory.createConnection(USER, PASSWORD);
> connection.setExceptionListener(new MyExceptionListener());
> connection.start();
> Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
> for (int i = 0; i <= 10; i++)
> {
> MessageProducer producer = session.createProducer(queue);
> TextMessage message = session.createTextMessage("Hello world from Java " + i + " !");
> Thread.sleep(1000L);
> producer.send(message, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY,
> Message.DEFAULT_TIME_TO_LIVE);
> }
> connection.close();
> } catch (Exception exp)
> {
> System.out.println("Caught exception, exiting.");
> exp.printStackTrace();
> System.exit(1);
> }
> }
> private static class MyExceptionListener implements ExceptionListener
> {
> public void onException(JMSException exception)
> {
> System.out.println("Connection ExceptionListener fired, exiting.");
> exception.printStackTrace();
> System.exit(1);
> }
> }
> }
> #!/usr/bin/env python
> from qpid.messaging import *
> url = "localhost:5673"
> queue = "examples"
> connection = Connection(url)
> try:
> connection.open()
> session = connection.session()
> while True:
> receiver = session.receiver(queue)
> message = receiver.fetch()
> print "got message"
> print message.content
> #session.acknowledge()
> except MessagingError,m:
> print "exeption: " , m
> connection.close()
> Note: If the queue is empty and we try to read, no writing can be done. The client (java), will throw an exception:
> javax.jms.JMSException: java.lang.NullPointerException [condition = amqp:connection:forced]
> at org.apache.qpid.jms.provider.amqp.AmqpAbstractResource.getRemoteError(AmqpAbstractResource.java:234)
> at org.apache.qpid.jms.provider.amqp.AmqpAbstractResource.remotelyClosed(AmqpAbstractResource.java:170)
> at org.apache.qpid.jms.provider.amqp.AmqpAbstractResource.processRemoteClose(AmqpAbstractResource.java:291)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdates(AmqpProvider.java:734)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1500(AmqpProvider.java:87)
> at org.apache.qpid.jms.provider.amqp.AmqpProvider$16.run(AmqpProvider.java:667)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> If the queue has messages, the broker will crash when we consuming messages (python).
> The following trace generated by the broker:
> 2015-06-13 11:48:57,262 DEBUG [IoReceiver - /127.0.0.1:48469] (transport.Connection) - RECV: [conn:29464cc5] ch=0 MessageFlow(destination=0, unit=MESSAGE, value=1)
> 2015-06-13 11:48:57,262 DEBUG [IoReceiver - /127.0.0.1:48469] (transport.Session) - identify: ch=0, commandId=5
> 2015-06-13 11:48:57,262 DEBUG [IoReceiver - /127.0.0.1:48469] (transport.Session) - ssn:"fb01ce9e-fc06-455a-abd7-c1c7df6b8664:0" ch=0 processed([5,5]) 4 4
> 2015-06-13 11:48:57,262 DEBUG [IoReceiver - /127.0.0.1:48469] (transport.Session) - ssn:"fb01ce9e-fc06-455a-abd7-c1c7df6b8664:0" processed: {[0, 4]}
> 2015-06-13 11:48:57,262 DEBUG [pool-1-thread-15] (transport.Connection) - FLUSH: [conn:29464cc5]
> 2015-06-13 11:48:57,262 DEBUG [pool-1-thread-15] (transport.Connection) - FLUSH: [conn:29464cc5]
> ########################################################################
> #
> # Unhandled Exception java.lang.NullPointerException in Thread pool-1-thread-15
> #
> # Exiting
> #
> ########################################################################
> java.lang.NullPointerException
> at java.util.HashMap.putMapEntries(HashMap.java:500)
> at java.util.HashMap.<init>(HashMap.java:489)
> at org.apache.qpid.server.protocol.v1_0.MessageMetaData_1_0$MessageHeader_1_0.getHeadersAsMap(MessageMetaData_1_0.java:586)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convertMetaData(MessageConverter_1_0_to_v0_10.java:181)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convertToStoredMessage(MessageConverter_1_0_to_v0_10.java:70)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convert(MessageConverter_1_0_to_v0_10.java:60)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convert(MessageConverter_1_0_to_v0_10.java:42)
> at org.apache.qpid.server.protocol.v0_10.ConsumerTarget_0_10.send(ConsumerTarget_0_10.java:218)
> at org.apache.qpid.server.queue.QueueConsumerImpl.send(QueueConsumerImpl.java:469)
> at org.apache.qpid.server.queue.AbstractQueue.deliverMessage(AbstractQueue.java:1323)
> at org.apache.qpid.server.queue.AbstractQueue.attemptDelivery(AbstractQueue.java:2069)
> at org.apache.qpid.server.queue.AbstractQueue.processQueue(AbstractQueue.java:2237)
> at org.apache.qpid.server.queue.QueueRunner$1.run(QueueRunner.java:77)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:360)
> at org.apache.qpid.server.queue.QueueRunner.run(QueueRunner.java:68)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> 2015-06-13 11:48:57,264 ERROR [pool-1-thread-15] (server.Main) - Uncaught exception, shutting down.
> java.lang.NullPointerException
> at java.util.HashMap.putMapEntries(HashMap.java:500)
> at java.util.HashMap.<init>(HashMap.java:489)
> at org.apache.qpid.server.protocol.v1_0.MessageMetaData_1_0$MessageHeader_1_0.getHeadersAsMap(MessageMetaData_1_0.java:586)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convertMetaData(MessageConverter_1_0_to_v0_10.java:181)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convertToStoredMessage(MessageConverter_1_0_to_v0_10.java:70)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convert(MessageConverter_1_0_to_v0_10.java:60)
> at org.apache.qpid.server.protocol.converter.v0_10_v1_0.MessageConverter_1_0_to_v0_10.convert(MessageConverter_1_0_to_v0_10.java:42)
> at org.apache.qpid.server.protocol.v0_10.ConsumerTarget_0_10.send(ConsumerTarget_0_10.java:218)
> at org.apache.qpid.server.queue.QueueConsumerImpl.send(QueueConsumerImpl.java:469)
> at org.apache.qpid.server.queue.AbstractQueue.deliverMessage(AbstractQueue.java:1323)
> at org.apache.qpid.server.queue.AbstractQueue.attemptDelivery(AbstractQueue.java:2069)
> at org.apache.qpid.server.queue.AbstractQueue.processQueue(AbstractQueue.java:2237)
> at org.apache.qpid.server.queue.QueueRunner$1.run(QueueRunner.java:77)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:360)
> at org.apache.qpid.server.queue.QueueRunner.run(QueueRunner.java:68)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> 2015-06-13 11:48:57,265 INFO [pool-1-thread-16] (subscription.state) - [Queue Delivery] [sub:1(vh(/default)/qu(examples)] SUB-1003 : State : SUSPENDED
> The reciever will produce this error (python):
> exeption: connection aborted
> Traceback (most recent call last):
> File "examples/api/hello", line 27, in <module>
> connection.close()
> File "<string>", line 6, in close
> File "/home/mansour/workspace/sources/qpid-python-0.32/qpid/messaging/endpoints.py", line 345, in close
> ssn.close(timeout=timeout)
> File "<string>", line 6, in close
> File "/home/mansour/workspace/sources/qpid-python-0.32/qpid/messaging/endpoints.py", line 795, in close
> self.sync(timeout=timeout)
> File "<string>", line 6, in sync
> File "/home/mansour/workspace/sources/qpid-python-0.32/qpid/messaging/endpoints.py", line 786, in sync
> if not self._ewait(lambda: not self.outgoing and not self.acked, timeout=timeout):
> File "/home/mansour/workspace/sources/qpid-python-0.32/qpid/messaging/endpoints.py", line 596, in _ewait
> result = self.connection._ewait(lambda: self.error or predicate(), timeout)
> File "/home/mansour/workspace/sources/qpid-python-0.32/qpid/messaging/endpoints.py", line 234, in _ewait
> self.check_error()
> File "/home/mansour/workspace/sources/qpid-python-0.32/qpid/messaging/endpoints.py", line 227, in check_error
> raise e
> qpid.messaging.exceptions.ConnectionError: connection aborted
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org