Salut
j'utilise activemq 5.4.1
Je voudrais utiliser producerFlowControl pour administrer mes queues
Mon problème est que je j'ai une confusion entre l'attribut memoryLimit de l'element policyEntry et l'attribut limit danbs les elements memoryUsage,storeUsage et tempUsage.
En fait j'ai essayé de bombarder mon queue avec cette configuration:
J'utilise le mode persistence.
Code : Sélectionner tout - Visualiser dans une fenêtre à part
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33 .. <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic=">" producerFlowControl="true" memoryLimit="1mb"> <pendingSubscriberPolicy> <vmCursor /> </pendingSubscriberPolicy> </policyEntry> <policyEntry queue=">" producerFlowControl="true" memoryLimit="10mb"> <pendingQueuePolicy> <vmQueueCursor/> </pendingQueuePolicy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> .. <systemUsage> <systemUsage sendFailIfNoSpaceAfterTimeout="60000"> <memoryUsage> <memoryUsage limit="200 mb"/> </memoryUsage> <storeUsage> <storeUsage limit="1 gb"/> </storeUsage> <tempUsage> <tempUsage limit="100 mb"/> </tempUsage> </systemUsage> </systemUsage>
Je m'attendais à ce que une exception est lévé lorsque mon queue depasse 1m(memoryLimit) mais rien ne s'est passé!!
Quand alors l'exception est lévé?
Partager