1. Your send() method needs to call super.send() after doing your custom
work, otherwise the message will never be sent to the real Broker object.
Please review the wiki page I referred to earlier, which covers how to
implement an interceptor.
2. To me it sounds like your plugin isn't getting installed. Do you have
any indication that it is, from logs or some other mechanism? And can you
please share the code of the class that implements BrokerPlugin, to confirm
that your installPlugin() method looks right, and the XML block where you
create the plugin bean?
Tim
On Nov 24, 2017 8:39 AM, "Gupta Bharat" <bharat.gu...@scania.com> wrote:
> Hello,
>
> I tried implementing the method as below:
>
> public void send(ProducerBrokerExchange producerExchange,
> ActiveMQMessage messageSend) throws JMSException
> {
> byte[] messageBytes = messageSend.getContent().data;
> String message = new String(messageBytes);
> logger.info("messageBody" + message);
> }
>
> Also I am publishing a message on a topic even though this send() method
> is not been called as logger.info is not getting printed in my Custom
> Plugin.
>
> Could you please help me on this?
>
> Regards,
> Bharat Gupta
> Development & Support | Platform Technician, IXCB | Scania IT
> Mobile: +46700869007, +91-9718483802
> bharat.gu...@scania.com
>
>
> -----Original Message-----
> From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
> Sent: Friday, November 24, 2017 7:15 PM
> To: ActiveMQ Users <users@activemq.apache.org>
> Cc: users-ow...@activemq.apache.org
> Subject: Re: ActiveMQ custom plugin
>
> As I said in your other thread, you would do that by implementing code in
> the send() method of your subclass of BrokerFilter, which you would create
> and return in your installPlugin() method.
>
> Tim
>
> On Nov 24, 2017 3:51 AM, "Gupta Bharat" <bharat.gu...@scania.com> wrote:
>
> Hello,
>
> I have a scenario as follows:
>
>
> 1. I have Custom Plugins that decrypts the data and validates it.
>
> 2. I am getting Encrypted data (token) from user that need to be
> decrypted on custom plugin.
>
> 3. Client is accessing the broker using mqtt protocol
>
> Need Solution for the following:
>
> 1. Before getting data onto topic on ACtiveMQ broker I need to
> validate the data(token) in my custom plugin
>
> 2. How to extract a data what customer is sending? So that I can
> extract the data, decrypt the message and validate.
>
>
> Implementation so far:
>
> 1. Custom Plugin is ready and JAR has been added in <ActiveMQ>/libs
>
> 2. Added the plugin configuration in activemq.xml
>
>
> Could anyone help me with a solution for the same as it's critical case.
>
> Thank you In Advance
>
> Regards,
> Bharat Gupta
> Development & Support | Platform Technician, IXCB | Scania IT
> Mobile: +46700869007, +91-9718483802
> bharat.gu...@scania.com<mailto:bharat.gu...@scania.com>
>
