How to send XML message from Python Client to a Spring boot microservice

I have a python client using "stomp.py" library which I use to send a XML payload to a Spring boot microservice which has the implementation to deserialise JMS messages.

I have a simple python class

class ActiveMqMessageProducer():



    def active_mq_props(self):

       active_mq_property = PropertyParser.PropertyParser().get_property(property_for='active-mq')

       return {'username': active_mq_property['username'], 'password': active_mq_property['password'], 'topic': active_mq_property['topic']}



    def active_mq_connection(self):

       props = self.active_mq_props()

       conn = stomp.StompConnection12()

       conn.start()

       conn.connect(username=props['username'], passcode=props['password'], wait=True)

       return conn



    def send_payload(self, payload):

       props = self.active_mq_props()

       conn = self.active_mq_connection()

       conn.send(destination=f'/topic/{props["topic"]}', body=payload)

       conn.disconnect()

When I send the below payload

<?xml version="1.0" encoding="utf-8"?>

<line timestamp="2018-03-14T14:03:11+0000" id="866381">

    <total/>

</line>

to Spring boot micro service I get an error

threw exception; nested exception is java.lang.ClassCastException: 

org.apache.activemq.command.ActiveMQBytesMessage cannot be cast to 

org.apache.activemq.command.ActiveMQTextMessage.

I understand the above exception but I am not able to set the correct content-type, headers in the python client so this exception won't happen.

I have tried a few variations but all in vain.
Can someone shed some light as to what I need to set the content-type, headers in the client.
Thanks in advance.

asked Nov 20 '18 at 5:29

user1126946

72113

add a comment |

I have a python client using "stomp.py" library which I use to send a XML payload to a Spring boot microservice which has the implementation to deserialise JMS messages.

I have a simple python class

class ActiveMqMessageProducer():



    def active_mq_props(self):

       active_mq_property = PropertyParser.PropertyParser().get_property(property_for='active-mq')

       return {'username': active_mq_property['username'], 'password': active_mq_property['password'], 'topic': active_mq_property['topic']}



    def active_mq_connection(self):

       props = self.active_mq_props()

       conn = stomp.StompConnection12()

       conn.start()

       conn.connect(username=props['username'], passcode=props['password'], wait=True)

       return conn



    def send_payload(self, payload):

       props = self.active_mq_props()

       conn = self.active_mq_connection()

       conn.send(destination=f'/topic/{props["topic"]}', body=payload)

       conn.disconnect()

When I send the below payload

<?xml version="1.0" encoding="utf-8"?>

<line timestamp="2018-03-14T14:03:11+0000" id="866381">

    <total/>

</line>

to Spring boot micro service I get an error

threw exception; nested exception is java.lang.ClassCastException: 

org.apache.activemq.command.ActiveMQBytesMessage cannot be cast to 

org.apache.activemq.command.ActiveMQTextMessage.

I understand the above exception but I am not able to set the correct content-type, headers in the python client so this exception won't happen.

I have tried a few variations but all in vain.
Can someone shed some light as to what I need to set the content-type, headers in the client.
Thanks in advance.

asked Nov 20 '18 at 5:29

user1126946

72113

add a comment |

I have a python client using "stomp.py" library which I use to send a XML payload to a Spring boot microservice which has the implementation to deserialise JMS messages.

I have a simple python class

class ActiveMqMessageProducer():



    def active_mq_props(self):

       active_mq_property = PropertyParser.PropertyParser().get_property(property_for='active-mq')

       return {'username': active_mq_property['username'], 'password': active_mq_property['password'], 'topic': active_mq_property['topic']}



    def active_mq_connection(self):

       props = self.active_mq_props()

       conn = stomp.StompConnection12()

       conn.start()

       conn.connect(username=props['username'], passcode=props['password'], wait=True)

       return conn



    def send_payload(self, payload):

       props = self.active_mq_props()

       conn = self.active_mq_connection()

       conn.send(destination=f'/topic/{props["topic"]}', body=payload)

       conn.disconnect()

When I send the below payload

<?xml version="1.0" encoding="utf-8"?>

<line timestamp="2018-03-14T14:03:11+0000" id="866381">

    <total/>

</line>

to Spring boot micro service I get an error

threw exception; nested exception is java.lang.ClassCastException: 

org.apache.activemq.command.ActiveMQBytesMessage cannot be cast to 

org.apache.activemq.command.ActiveMQTextMessage.

I understand the above exception but I am not able to set the correct content-type, headers in the python client so this exception won't happen.

I have tried a few variations but all in vain.
Can someone shed some light as to what I need to set the content-type, headers in the client.
Thanks in advance.

asked Nov 20 '18 at 5:29

user1126946

72113

I have a python client using "stomp.py" library which I use to send a XML payload to a Spring boot microservice which has the implementation to deserialise JMS messages.

I have a simple python class

class ActiveMqMessageProducer():



    def active_mq_props(self):

       active_mq_property = PropertyParser.PropertyParser().get_property(property_for='active-mq')

       return {'username': active_mq_property['username'], 'password': active_mq_property['password'], 'topic': active_mq_property['topic']}



    def active_mq_connection(self):

       props = self.active_mq_props()

       conn = stomp.StompConnection12()

       conn.start()

       conn.connect(username=props['username'], passcode=props['password'], wait=True)

       return conn



    def send_payload(self, payload):

       props = self.active_mq_props()

       conn = self.active_mq_connection()

       conn.send(destination=f'/topic/{props["topic"]}', body=payload)

       conn.disconnect()

When I send the below payload

<?xml version="1.0" encoding="utf-8"?>

<line timestamp="2018-03-14T14:03:11+0000" id="866381">

    <total/>

</line>

to Spring boot micro service I get an error

threw exception; nested exception is java.lang.ClassCastException: 

org.apache.activemq.command.ActiveMQBytesMessage cannot be cast to 

org.apache.activemq.command.ActiveMQTextMessage.

I understand the above exception but I am not able to set the correct content-type, headers in the python client so this exception won't happen.

I have tried a few variations but all in vain.
Can someone shed some light as to what I need to set the content-type, headers in the client.
Thanks in advance.

python-3.x activemq stomp

asked Nov 20 '18 at 5:29

user1126946

72113

asked Nov 20 '18 at 5:29

user1126946

72113

asked Nov 20 '18 at 5:29

user1126946

72113

asked Nov 20 '18 at 5:29

user1126946

72113

asked Nov 20 '18 at 5:29

user1126946

72113

add a comment |

1 Answer
1

active

oldest

votes

I have solved the issue and did no change other than a simple addition to my existing code. It was as simple as

conn = stomp.StompConnection12(auto_content_length=False).

The information is kinda hidden and lies within the stomp protocol documentation.
But if anyone stumbles with a similar issue as I had, the above piece of code solved my issue.

answered Nov 20 '18 at 22:05

user1126946

72113

add a comment |

Your Answer

StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");

StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);

StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});

function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});

}
});

draft saved

draft discarded

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53386768%2fhow-to-send-xml-message-from-python-client-to-a-spring-boot-microservice%23new-answer', 'question_page');
}
);

Post as a guest

Name

Required, but never shown

1 Answer
1

active

oldest

votes

1 Answer
1

active

oldest

votes

I have solved the issue and did no change other than a simple addition to my existing code. It was as simple as

conn = stomp.StompConnection12(auto_content_length=False).

The information is kinda hidden and lies within the stomp protocol documentation.
But if anyone stumbles with a similar issue as I had, the above piece of code solved my issue.

answered Nov 20 '18 at 22:05

user1126946

72113

add a comment |

I have solved the issue and did no change other than a simple addition to my existing code. It was as simple as

conn = stomp.StompConnection12(auto_content_length=False).

The information is kinda hidden and lies within the stomp protocol documentation.
But if anyone stumbles with a similar issue as I had, the above piece of code solved my issue.

answered Nov 20 '18 at 22:05

user1126946

72113

add a comment |

I have solved the issue and did no change other than a simple addition to my existing code. It was as simple as

conn = stomp.StompConnection12(auto_content_length=False).

The information is kinda hidden and lies within the stomp protocol documentation.
But if anyone stumbles with a similar issue as I had, the above piece of code solved my issue.

answered Nov 20 '18 at 22:05

user1126946

72113

I have solved the issue and did no change other than a simple addition to my existing code. It was as simple as

conn = stomp.StompConnection12(auto_content_length=False).

The information is kinda hidden and lies within the stomp protocol documentation.
But if anyone stumbles with a similar issue as I had, the above piece of code solved my issue.

answered Nov 20 '18 at 22:05

user1126946

72113

answered Nov 20 '18 at 22:05

user1126946

72113

answered Nov 20 '18 at 22:05

user1126946

72113

answered Nov 20 '18 at 22:05

user1126946

72113

add a comment |

draft saved

draft discarded

Thanks for contributing an answer to Stack Overflow!

Please be sure to answer the question. Provide details and share your research!

But avoid …

Asking for help, clarification, or responding to other answers.

Making statements based on opinion; back them up with references or personal experience.

To learn more, see our tips on writing great answers.

draft saved

draft discarded

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Post as a guest

Name

Required, but never shown

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Name

Required, but never shown

Name

Required, but never shown

This page is only for reference, If you need detailed information, please check here

Search This Blog

Ufyukyu