[
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 ?
I suggest returning the converted value of the original object message rather
than null.
{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 ?
I suggest returning the converted value of the original object message rather
than returning null.
{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: Improvement
> 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 ?
> I suggest returning the converted value of the original object message rather
> than null.
>
> {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)
