The data is not corrupted, since I was able to get the data using Ruby by
importing mcollective and using native mcollective decode.
And this what the code I tried in Python,
def run(self):
client = Stomp(self.config)
yield client.connect()
headers = {StompSpec.ACK_HEADER: StompSpec.ACK_CLIENT_INDIVIDUAL,
'activemq.prefetchSize': '10000'}
client.subscribe(self.QUEUE, headers,
listener=SubscriptionListener(self.consume,
errorDestination=self.ERROR_QUEUE))
def consume(self, client, frame):
data = json.loads(base64.b64decode(frame.body))
print(data)
On Sunday, January 21, 2018 at 4:33:24 PM UTC+5:30, R.I.Pienaar wrote:
>
>
> On Sun, 21 Jan 2018, at 10:50, [email protected] <javascript:> wrote:
> > Hi,
> >
> > Am trying to use different consumer which can consume messages which is
> > being called with reply-to option and the consumer which am trying to
> use
> > is stompest (https://github.com/nikipore/stompest) which is Python
> based.
> > Am able to configure this and its receiving the message but unable to
> > decode the message using base64. Am not using any security plugin in my
> > mcollective environment so I hope MCollective does plain base64 encoding
> > only, so with that I tried to decode the message in Python using same
> > base64 but its not working. Sometimes getting "Incorrect Padding" issue
> and
> > sometimes byte related errors are appearing. So looking proper way to
> > decode the mcollective message using python and get the message payload
> > data.
> >
>
> padding error means some data at the end is missing - often normal -
> base64 data has to be dividable by 4, if not add "=" at the end till it is.
> Then it should work
>
> not sure what happens that your data is corrupt though
>
> --
> R.I.Pienaar / www.devco.net / @ripienaar
>
--
---
You received this message because you are subscribed to the Google Groups
"mcollective-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
For more options, visit https://groups.google.com/d/optout.
