Hi,
I am trying to use the Throttle mediator in a proxy that is listening to a
JMS Queue.
I would to limit the number of messages it process in a time interval. And
the rejected ones would be stored in a messageStore to be processed later.
When consuming the messages from queue, it seems the policy is not
activated but when I call the proxy from SOAPUI, I see the policy working.
Does this work for a jms listener?
Follow my policy:
<throttle id="lThrottle">
<policy>
<wsp:Policy wsu:id="WSO2MediatorThrottlingPolicy"
xmlns:wsp="http://schemas.xmlsoap.org/ws/2004/09/policy"; xmlns:wsu="
http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd
">
<throttle:MediatorThrottleAssertion xmlns:throttle="
http://www.wso2.org/products/wso2commons/throttle";>
<throttle:MaximumConcurrentAccess>2</throttle:MaximumConcurrentAccess>
<wsp:Policy>
<throttle:ID
throttle:type="IP">other</throttle:ID>
<wsp:Policy>
<throttle:Control>
<wsp:Policy>
<throttle:MaximumCount>5</throttle:MaximumCount>
<throttle:UnitTime>10000</throttle:UnitTime>
<throttle:ProhibitTimePeriod
wsp:Optional="true">2000</throttle:ProhibitTimePeriod>
</wsp:Policy>
</throttle:Control>
</wsp:Policy>
</wsp:Policy>
</throttle:MediatorThrottleAssertion>
</wsp:Policy>
</policy>
<onReject>
<log>
<property name="AQListener" value="** Request
Denied from Oracle AQ - Sending to the messageStore **"/>
</log>
<drop/>
</onReject>
<onAccept>
<log level="custom">
<property name="AQListener" value="** Request
Accepted from Oracle AQ**"/>
</log>
<property name="FORCE_SC_ACCEPTED" scope="axis2"
type="STRING" value="true"/>
<property name="OUT_ONLY" scope="default" type="STRING"
value="true"/>
<header name="To" scope="default" value="
http://localhost:8280/services/ChannelAQ"/>
<!-- <header
expression="get-property('adc.topic.endpoint.url')" name="To"/>-->
<send>
<endpoint key="NoSuspensionEP"/>
</send>
</onAccept>
</throttle>
Thanks,
--
Francisco Ribeiro
*SCEA|SCJP|SCWCD|IBM Certified SOA Associate*
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
