You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Alistair Young <al...@uhi.ac.uk> on 2011/09/27 09:49:53 UTC
isAllowedToConsume not called on embedded broker
is there any reason why MessageAuthorizationPolicy::isAllowedToConsume is not called from this?
broker = new BrokerService();
broker.setMessageAuthorizationPolicy(new MessageGuard());
broker.addConnector(BROKER_URL);
broker.start();
MessageGuard::isAllowedToConsume is never called when a message is sent to the embedded broker. It's called fine when used on the server. Doesn't work in a JUnit test.
Alistair
--
mov eax,1
mov ebx,0
int 80h
Re: isAllowedToConsume not called on embedded broker
Posted by Alistair Young <al...@uhi.ac.uk>.
I use tcp://localhost:61616
Alistair
--
mov eax,1
mov ebx,0
int 80h
On 27 Sep 2011, at 11:18, Gary Tully wrote:
> it is not applied to the vm transport, you would need to use tcp to
> connect to your embedded broker to make use of authorization.
>
> On 27 September 2011 08:49, Alistair Young <al...@uhi.ac.uk> wrote:
>> is there any reason why MessageAuthorizationPolicy::isAllowedToConsume is not called from this?
>>
>> broker = new BrokerService();
>> broker.setMessageAuthorizationPolicy(new MessageGuard());
>> broker.addConnector(BROKER_URL);
>> broker.start();
>>
>> MessageGuard::isAllowedToConsume is never called when a message is sent to the embedded broker. It's called fine when used on the server. Doesn't work in a JUnit test.
>>
>> Alistair
>>
>> --
>> mov eax,1
>> mov ebx,0
>> int 80h
>>
>>
>>
>>
>>
>
>
>
> --
> http://fusesource.com
> http://blog.garytully.com
Re: isAllowedToConsume not called on embedded broker
Posted by Gary Tully <ga...@gmail.com>.
it is not applied to the vm transport, you would need to use tcp to
connect to your embedded broker to make use of authorization.
On 27 September 2011 08:49, Alistair Young <al...@uhi.ac.uk> wrote:
> is there any reason why MessageAuthorizationPolicy::isAllowedToConsume is not called from this?
>
> broker = new BrokerService();
> broker.setMessageAuthorizationPolicy(new MessageGuard());
> broker.addConnector(BROKER_URL);
> broker.start();
>
> MessageGuard::isAllowedToConsume is never called when a message is sent to the embedded broker. It's called fine when used on the server. Doesn't work in a JUnit test.
>
> Alistair
>
> --
> mov eax,1
> mov ebx,0
> int 80h
>
>
>
>
>
--
http://fusesource.com
http://blog.garytully.com