You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Park Min Sung (JIRA)" <ji...@apache.org> on 2019/06/25 08:37:00 UTC
[jira] [Updated] (NIFI-6396) Cannot handle ObjectMessage in
ConsumeJMS processor
[ https://issues.apache.org/jira/browse/NIFI-6396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Park Min Sung updated NIFI-6396:
--------------------------------
Description:
I am using the ConsumeJMS processor with JMSConnectionFactoryProviders.
but, this processor only handle 'TextMessage' and 'ByteMessage' ? How can I handle Object type message ?
Please tell me how to do solve it ?
{code:java}
ERROR [Timer-Driven Process Thread-62] o.apache.nifi.jms.processors.ConsumeJMS ConsumeJMS[id=c06ed911-d011-3647-999d-bd13dd54761c] Received a JMS Message that was neither a TextMessage nor a BytesMessage [ActiveMQObjectMessage {commandId = 6695, responseRequired = true, messageId = ID:sinbaram02-41459-1561113357706-1:1:4:1:437, originalDestination = null, originalTransactionId = null, producerId = ID:sinbaram02-41459-1561113357706-1:1:4:1, destination = queue://thinkbig.provenance-event-stats, transactionId = null, expiration = 0, timestamp = 1561449523947, arrival = 0, brokerInTime = 1561449523948, brokerOutTime = 1561449523948, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@61a5fc7b, marshalledProperties = org.apache.activemq.util.ByteSequence@5aec4823, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {timestamp=1561449523947}, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false}]; will skip this message.
{code}
was:
I am using the ConsumeJMS processor with JMSConnectionFactoryProviders.
but, this processor only handle 'TextMessage' and 'ByteMessage' ? How can I handle Object type message ?
Please tell me how to do solve it ?
!image-2019-06-25-17-34-51-000.png!
{code:java}
ERROR [Timer-Driven Process Thread-62] o.apache.nifi.jms.processors.ConsumeJMS ConsumeJMS[id=c06ed911-d011-3647-999d-bd13dd54761c] Received a JMS Message that was neither a TextMessage nor a BytesMessage [ActiveMQObjectMessage {commandId = 6695, responseRequired = true, messageId = ID:sinbaram02-41459-1561113357706-1:1:4:1:437, originalDestination = null, originalTransactionId = null, producerId = ID:sinbaram02-41459-1561113357706-1:1:4:1, destination = queue://thinkbig.provenance-event-stats, transactionId = null, expiration = 0, timestamp = 1561449523947, arrival = 0, brokerInTime = 1561449523948, brokerOutTime = 1561449523948, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@61a5fc7b, marshalledProperties = org.apache.activemq.util.ByteSequence@5aec4823, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {timestamp=1561449523947}, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false}]; will skip this message.
{code}
> Cannot handle ObjectMessage in ConsumeJMS processor
> ---------------------------------------------------
>
> Key: NIFI-6396
> URL: https://issues.apache.org/jira/browse/NIFI-6396
> Project: Apache NiFi
> Issue Type: Bug
> Affects Versions: 1.6.0
> Reporter: Park Min Sung
> Priority: Major
>
>
> I am using the ConsumeJMS processor with JMSConnectionFactoryProviders.
> but, this processor only handle 'TextMessage' and 'ByteMessage' ? How can I handle Object type message ?
> Please tell me how to do solve it ?
>
> {code:java}
> ERROR [Timer-Driven Process Thread-62] o.apache.nifi.jms.processors.ConsumeJMS ConsumeJMS[id=c06ed911-d011-3647-999d-bd13dd54761c] Received a JMS Message that was neither a TextMessage nor a BytesMessage [ActiveMQObjectMessage {commandId = 6695, responseRequired = true, messageId = ID:sinbaram02-41459-1561113357706-1:1:4:1:437, originalDestination = null, originalTransactionId = null, producerId = ID:sinbaram02-41459-1561113357706-1:1:4:1, destination = queue://thinkbig.provenance-event-stats, transactionId = null, expiration = 0, timestamp = 1561449523947, arrival = 0, brokerInTime = 1561449523948, brokerOutTime = 1561449523948, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@61a5fc7b, marshalledProperties = org.apache.activemq.util.ByteSequence@5aec4823, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {timestamp=1561449523947}, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false}]; will skip this message.
> {code}
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)