UNKNOWN
Apr 05, 2024
+Apr 06, 2024
1
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
diff --git a/Explanation/SarraPluginDev.html b/Explanation/SarraPluginDev.html index d27becd0c..fe64b0e4e 100644 --- a/Explanation/SarraPluginDev.html +++ b/Explanation/SarraPluginDev.html @@ -151,7 +151,7 @@UNKNOWN
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
Apr 05, 2024
+Apr 06, 2024
A Sarracenia data pump is a web (or sftp) server with notifications for subscribers diff --git a/How2Guides/subscriber.html b/How2Guides/subscriber.html index 6401ed95e..6b8b3d5b1 100644 --- a/How2Guides/subscriber.html +++ b/How2Guides/subscriber.html @@ -143,7 +143,7 @@
UNKNOWN
Apr 05, 2024
+Apr 06, 2024
1
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
diff --git a/Reference/sr3_cpump.1.html b/Reference/sr3_cpump.1.html index 7e294a042..8b9b8fc2d 100644 --- a/Reference/sr3_cpump.1.html +++ b/Reference/sr3_cpump.1.html @@ -127,7 +127,7 @@1
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
diff --git a/Reference/sr3_credentials.7.html b/Reference/sr3_credentials.7.html index b02377774..ee68cc044 100644 --- a/Reference/sr3_credentials.7.html +++ b/Reference/sr3_credentials.7.html @@ -124,7 +124,7 @@7
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
diff --git a/Reference/sr3_options.7.html b/Reference/sr3_options.7.html index 873659ce8..c232939bc 100644 --- a/Reference/sr3_options.7.html +++ b/Reference/sr3_options.7.html @@ -128,7 +128,7 @@7
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
@@ -712,7 +712,9 @@The AMQP durable option, on queue declarations. If set to True, the broker will preserve the queue across broker reboots. -It means writes the queue is on disk if the broker is restarted.
+The queue will be written to and recovered from disk if the broker is restarted. +Note: only persistent messages will remain in a durable queue after a broker restart. +Persistent messages can be published by enabling the persistent option (it is enabled by default).
The persistent option sets the delivery_mode for an AMQP message. When True,
+persistent messages will be published (delivery_mode=2), when False, transient
+(non-durable, delivery_mode=1) messages will be published.
Persistent messages are written to disk by the broker, and will survive a broker restart. +Any transient messages in a queue will be lost when a broker is restarted. Note: persistent +messages will only survive a broker restart when they reside in a durable queue. Non-durable +queues, including all messages inside them, will be lost when a broker is restarted.
+Specification of a remote server resources to query with a poll diff --git a/Reference/sr3_post.1.html b/Reference/sr3_post.1.html index 4b40fd369..40bbabe49 100644 --- a/Reference/sr3_post.1.html +++ b/Reference/sr3_post.1.html @@ -128,7 +128,7 @@
1
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
diff --git a/Reference/sr_post.7.html b/Reference/sr_post.7.html index 4eafd5932..5a0507280 100644 --- a/Reference/sr_post.7.html +++ b/Reference/sr_post.7.html @@ -133,7 +133,7 @@7
Apr 05, 2024
+Apr 06, 2024
UNKNOWN
diff --git a/Tutorials/Install.html b/Tutorials/Install.html index 72280c5a2..3bc728bb6 100644 --- a/Tutorials/Install.html +++ b/Tutorials/Install.html @@ -134,7 +134,7 @@UNKNOWN
Apr 05, 2024
+Apr 06, 2024
'delete', 'discard', 'download', 'dry_run', 'durable', 'exchangeDeclare', 'exchangeSplit', 'logReject', 'realpathFilter', \
'follow_symlinks', 'force_polling', 'inline', 'inlineOnly', 'inplace', 'logMetrics', 'logStdout', 'logReject', 'restore', \
'messageDebugDump', 'mirror', 'timeCopy', 'notify_only', 'overwrite', 'post_on_start', \
- 'permCopy', 'queueBind', 'queueDeclare', 'randomize', 'recursive', 'realpathPost', \
+ 'permCopy', 'persistent', 'queueBind', 'queueDeclare', 'randomize', 'recursive', 'realpathPost', \
'reconnect', 'report', 'reset', 'retry_refilter', 'retryEmptyBeforeExit', 'save', 'sundew_compat_regex_first_match_is_zero', \
'sourceFromExchange', 'statehost', 'users', 'v2compatRenameDoublePost'
]
diff --git a/_modules/sarracenia/moth/amqp.html b/_modules/sarracenia/moth/amqp.html
index 4576deecb..9058247d7 100644
--- a/_modules/sarracenia/moth/amqp.html
+++ b/_modules/sarracenia/moth/amqp.html
@@ -131,6 +131,7 @@ Source code for sarracenia.moth.amqp
'exchangeDeclare': True,
'expire': None,
'logLevel': 'info',
+ 'persistent': True,
'prefetch': 25,
'queueName': None,
'queueBind': True,
@@ -779,6 +780,11 @@ Source code for sarracenia.moth.amqp
sarracenia.durationToSeconds(self.o['message_ttl']) * 1000)
else:
ttl = "0"
+
+ if 'persistent' in self.o:
+ deliv_mode = 2 if self.o['persistent'] else 1
+ else:
+ deliv_mode = 2
raw_body, headers, content_type = PostFormat.exportAny( body, version, self.o['topicPrefix'], self.o )
@@ -814,7 +820,7 @@ Source code for sarracenia.moth.amqp
content_type=content_type,
application_headers=headers,
expire=ttl,
- delivery_mode=2)
+ delivery_mode=deliv_mode)
self.metrics['txByteCount'] += len(raw_body)
if headers:
self.metrics['txByteCount'] += len(''.join(str(headers)))
diff --git a/_sources/Reference/sr3_options.7.rst.txt b/_sources/Reference/sr3_options.7.rst.txt
index db4111bb3..7e5e948b0 100644
--- a/_sources/Reference/sr3_options.7.rst.txt
+++ b/_sources/Reference/sr3_options.7.rst.txt
@@ -686,7 +686,10 @@ durable (default: True)
The AMQP **durable** option, on queue declarations. If set to True,
the broker will preserve the queue across broker reboots.
-It means writes the queue is on disk if the broker is restarted.
+The queue will be written to and recovered from disk if the broker is restarted.
+
+Note: only *persistent* messages will remain in a durable queue after a broker restart.
+Persistent messages can be published by enabling the **persistent** option (it is enabled by default).
fileEvents
----------------------------
@@ -1305,6 +1308,18 @@ a file to be accepted.
The **permDefault** options specifies a mask, that is the permissions must be
at least what is specified.
+persistent (default: True)
+----------------------------------
+
+The **persistent** option sets the *delivery_mode* for an AMQP message. When True,
+persistent messages will be published (``delivery_mode=2``), when False, transient
+(non-durable, ``delivery_mode=1``) messages will be published.
+
+Persistent messages are written to disk by the broker, and will survive a broker restart.
+Any transient messages in a queue will be lost when a broker is restarted. Note: persistent
+messages will only survive a broker restart *when they reside in a durable queue*. Non-durable
+queues, including all messages inside them, will be lost when a broker is restarted.
+
pollUrl
-------------
diff --git a/_sources/fr/Reference/sr3_options.7.rst.txt b/_sources/fr/Reference/sr3_options.7.rst.txt
index d914d4041..260e96a68 100644
--- a/_sources/fr/Reference/sr3_options.7.rst.txt
+++ b/_sources/fr/Reference/sr3_options.7.rst.txt
@@ -671,6 +671,9 @@ L’option AMQP **durable**, sur les déclarations de fil d’attente. Si la val
le courtier conservera la fil d’attente lors des redémarrages du courtier.
Cela signifie que la fil d’attente est sur le disque si le courtier est redémarré.
+Remarque: seuls les messages *persistants* resteront dans une file d'attente durable après le redémarrage du courtier.
+Les messages persistants peuvent être publiés en activant l'option **persistant** (elle est activée par défaut).
+
fileEvents <évènement, évènement,...>
-------------------------------------
@@ -1280,6 +1283,20 @@ qu'un dossier puis être accepté.
Les options **permDefault** spécifient un masque, c’est-à-dire que les autorisations doivent être
au moins ce qui est spécifié.
+persistent (défaut: True)
+----------------------------------
+
+L'option **persistent** définit le *delivery_mode* pour un message AMQP. Lorsqu'il
+est choisi, les messages persistants seront publiés (``delivery_mode=2``). Lorsqu'ils
+ne le sont pas, ils seront placés en mode transitoire (non durables, ``delivery_mode=1``).
+
+Les messages persistants sont écrits sur le disque par le courtier et survivront au
+redémarrage du courtier. Tous les messages transitoires dans une file d’attente seront
+perdus au redémarrage d’un courtier. Une remarque : les messages persistants ne survivront
+pas le redémarrage du courtier *quand ils résident dans une file d'attente durable*.
+Non-durable les files d'attente, y compris tous les messages qu'elles contiennent,
+seront perdues au redémarrage d'un courtier.
+
pollUrl
-------
diff --git a/fr/CommentFaire/source.html b/fr/CommentFaire/source.html
index 44478b102..fbe894110 100644
--- a/fr/CommentFaire/source.html
+++ b/fr/CommentFaire/source.html
@@ -144,7 +144,7 @@ Enregistrement de révisionUNKNOWN
date:
-Apr 05, 2024
+Apr 06, 2024
Une pompe de données Sarracenia est un serveur Web (ou sftp) avec des notifications pour que les
diff --git a/fr/CommentFaire/subscriber.html b/fr/CommentFaire/subscriber.html
index 3b8dc26ff..147f31d6e 100644
--- a/fr/CommentFaire/subscriber.html
+++ b/fr/CommentFaire/subscriber.html
@@ -133,7 +133,7 @@
Enregistrement de révisionUNKNOWN
date:
-Apr 05, 2024
+Apr 06, 2024
Guide du développeur MetPX-SarraceniaUNKNOWN
date:
-Apr 05, 2024
+Apr 06, 2024
diff --git "a/fr/Contribution/mod\303\250le_de_page_man.html" "b/fr/Contribution/mod\303\250le_de_page_man.html"
index 2ea4d20f1..f48289c50 100644
--- "a/fr/Contribution/mod\303\250le_de_page_man.html"
+++ "b/fr/Contribution/mod\303\250le_de_page_man.html"
@@ -131,7 +131,7 @@ sr_titre
1
Date:
-Apr 05, 2024
+Apr 06, 2024
Version:
UNKNOWN
diff --git a/fr/Explication/SarraPluginDev.html b/fr/Explication/SarraPluginDev.html
index b73e13ff1..5039d7c9d 100644
--- a/fr/Explication/SarraPluginDev.html
+++ b/fr/Explication/SarraPluginDev.html
@@ -135,7 +135,7 @@ Travailler avec des pluginsUNKNOWN
date:
-Apr 05, 2024
+Apr 06, 2024
diff --git a/fr/Reference/sr3.1.html b/fr/Reference/sr3.1.html
index 9ed935402..420bb1cbb 100644
--- a/fr/Reference/sr3.1.html
+++ b/fr/Reference/sr3.1.html
@@ -127,7 +127,7 @@ sr3 Sarracenia CLI1
Date:
-Apr 05, 2024
+Apr 06, 2024
Version:
UNKNOWN
diff --git a/fr/Reference/sr3_cpump.1.html b/fr/Reference/sr3_cpump.1.html
index cd52dabec..cce6bf486 100644
--- a/fr/Reference/sr3_cpump.1.html
+++ b/fr/Reference/sr3_cpump.1.html
@@ -127,7 +127,7 @@ sr_shovel en C1
Date:
-Apr 05, 2024
+Apr 06, 2024
Version:
UNKNOWN
diff --git a/fr/Reference/sr3_credentials.7.html b/fr/Reference/sr3_credentials.7.html
index eb526d3ef..3342a313d 100644
--- a/fr/Reference/sr3_credentials.7.html
+++ b/fr/Reference/sr3_credentials.7.html
@@ -127,7 +127,7 @@ SR3 Credential: Format du Fichier7
Date:
-Apr 05, 2024
+Apr 06, 2024
Version:
UNKNOWN
diff --git a/fr/Reference/sr3_options.7.html b/fr/Reference/sr3_options.7.html
index abee00d95..28f328bd0 100644
--- a/fr/Reference/sr3_options.7.html
+++ b/fr/Reference/sr3_options.7.html
@@ -127,7 +127,7 @@ Format de fichier de configuration SR37
Date:
-Apr 05, 2024
+Apr 06, 2024
Version:
UNKNOWN
@@ -711,6 +711,8 @@ durable <flag> (défaut: True)
fileEvents <évènement, évènement,…>
@@ -1252,6 +1254,18 @@ permDefault, permDirDefault, permLog, permCopy
+persistent <flag> (défaut: True)
+L’option persistent définit le delivery_mode pour un message AMQP. Lorsqu’il
+est choisi, les messages persistants seront publiés (delivery_mode=2). Lorsqu’ils
+ne le sont pas, ils seront placés en mode transitoire (non durables, delivery_mode=1).
+Les messages persistants sont écrits sur le disque par le courtier et survivront au
+redémarrage du courtier. Tous les messages transitoires dans une file d’attente seront
+perdus au redémarrage d’un courtier. Une remarque : les messages persistants ne survivront
+pas le redémarrage du courtier quand ils résident dans une file d’attente durable.
+Non-durable les files d’attente, y compris tous les messages qu’elles contiennent,
+seront perdues au redémarrage d’un courtier.
+
pollUrl
Spécification de ressources d´une serveur à sonder
diff --git a/fr/Reference/sr3_post.1.html b/fr/Reference/sr3_post.1.html
index 0f6f5b42b..e280d605f 100644
--- a/fr/Reference/sr3_post.1.html
+++ b/fr/Reference/sr3_post.1.html
@@ -127,7 +127,7 @@
Publie la Disponibilitée d’un fichier aux abonnés.1
Date:
-Apr 05, 2024
+Apr 06, 2024
Version:
UNKNOWN
diff --git a/fr/Reference/sr_post.7.html b/fr/Reference/sr_post.7.html
index ea0ae61d2..160d794f8 100644
--- a/fr/Reference/sr_post.7.html
+++ b/fr/Reference/sr_post.7.html
@@ -127,7 +127,7 @@ Format/Protocole de messages d’annonce Sarracenia7
Date:
-Apr 05, 2024
+Apr 06, 2024
Version:
UNKNOWN
diff --git a/fr/Tutoriel/Installer.html b/fr/Tutoriel/Installer.html
index 7a22dca9d..2e1c980de 100644
--- a/fr/Tutoriel/Installer.html
+++ b/fr/Tutoriel/Installer.html
@@ -133,7 +133,7 @@ Enregistrement de révisionUNKNOWN
date:
-Apr 05, 2024
+Apr 06, 2024
]": [[20, "queue-queue-name-qn-name"], [106, "queue-queue-name-qn-name"]], "AMQP QUEUE BINDINGS": [[20, "amqp-queue-bindings"], [106, "amqp-queue-bindings"]], "subtopic (default: #)": [[20, "subtopic-amqp-pattern-default"], [62, "subtopic-amqp-pattern-default"], [106, "subtopic-amqp-pattern-default"]], "Client-side Filtering": [[20, "client-side-filtering"], [106, "client-side-filtering"]], "Brief Introduction to Regular Expressions": [[20, "brief-introduction-to-regular-expressions"], [106, "brief-introduction-to-regular-expressions"]], "accept, reject and accept_unmatch": [[20, "accept-reject-and-accept-unmatch"], [106, "accept-reject-and-accept-unmatch"]], "NAMING QUEUES": [[20, "naming-queues"]], "POSTING": [[20, "posting"]], "NAMING EXCHANGES": [[20, "naming-exchanges"]], "POLLING": [[20, "polling"]], "Advanced Polling": [[20, "advanced-polling"]], "COMPONENTS": [[20, "components"], [59, "components"]], "CPUMP": [[20, "cpump"], [106, "cpump"]], "FLOW": [[20, "flow"], [106, "flow"]], "POLL": [[20, "poll"], [106, "poll"]], "Repeated Scans and VIP": [[20, "repeated-scans-and-vip"]], "POST or WATCH": [[20, "post-or-watch"], [106, "post-or-watch"]], "File Partitioning": [[20, "file-partitioning"]], "SARRA": [[20, "sarra"], [106, "sarra"]], "Specific Consuming Requirements": [[20, "specific-consuming-requirements"]], "SENDER": [[20, "sender"], [106, "sender"]], "SETUP 1 : PUMP TO PUMP REPLICATION": [[20, "setup-1-pump-to-pump-replication"]], "DESTINATION SETUP 2 : METPX-SUNDEW LIKE DISSEMINATION": [[20, "destination-setup-2-metpx-sundew-like-dissemination"]], "SHOVEL": [[20, "shovel"], [106, "shovel"]], "SUBSCRIBE": [[20, "subscribe"], [106, "subscribe"]], "WATCH": [[20, "watch"], [106, "watch"]], "WINNOW": [[20, "winnow"], [106, "winnow"]], "Configurations": [[20, "configurations"], [106, "configurations"]], "flowCallbacks": [[20, "flowcallbacks"], [106, "flowcallbacks"]], "callback options": [[20, "callback-options"]], "Importing Extensions": [[20, "importing-extensions"]], "Deprecated v2 plugins": [[20, "deprecated-v2-plugins"]], "Environment Variables": [[20, "environment-variables"], [106, "environment-variables"]], "LOGS and MONITORING": [[20, "logs-and-monitoring"]], "CREDENTIALS": [[20, "credentials"]], "Credential Details": [[20, "credential-details"], [61, "credential-details"]], "PERIODIC PROCESSING": [[20, "periodic-processing"]], "sanity_log_dead (default: 1.5*housekeeping)": [[20, "sanity-log-dead-interval-default-1-5-housekeeping"], [62, "sanity-log-dead-interval-default-1-5-housekeeping"]], "nodup_ttl (default: off)": [[20, "nodup-ttl-off-on-999-default-off"]], "ERROR RECOVERY": [[20, "error-recovery"]], "EXAMPLES": [[20, "examples"], [59, "examples"]], "QUEUES and MULTIPLE STREAMS": [[20, "queues-and-multiple-streams"], [106, "queues-and-multiple-streams"]], "report and report_exchange": [[20, "report-and-report-exchange"], [62, "report-and-report-exchange"]], "INSTANCES": [[20, "instances"], [106, "instances"]], "vip - ACTIVE/PASSIVE OPTIONS": [[20, "vip-active-passive-options"], [62, "vip-active-passive-options"], [106, "vip-active-passive-options"]], "[\u2013blocksize ] (default: 0 (auto))": [[20, "blocksize-value-default-0-auto"], [106, "blocksize-value-default-0-auto"]], "[-pbd|\u2013post_baseDir ] (optional)": [[20, "pbd-post-basedir-path-optional"]], "post_baseUrl (MANDATORY)": [[20, "post-baseurl-url-mandatory"]], "post_exchange (default: xpublic)": [[20, "post-exchange-name-default-xpublic"], [62, "post-exchange-name-default-xpublic"], [106, "post-exchange-name-default-xpublic"]], "post_exchangeSplit (default: 0)": [[20, "post-exchangesplit-number-default-0"]], "Remote Configurations": [[20, "remote-configurations"], [59, "remote-configurations"], [106, "remote-configurations"]], "Extensions": [[20, "extensions"], [106, "extensions"]], "flowCallback and flowCallbackPrepend ": [[20, "flowcallback-and-flowcallbackprepend-class"]], "Identity": [[20, "identity"], [106, "identity"]], "Transfer": [[20, "transfer"], [106, "transfer"]], "ROLES - feeder/admin/declare": [[20, "roles-feeder-admin-declare"], [106, "roles-feeder-admin-declare"]], "subscriber": [[20, "subscriber"], [106, "subscriber"]], "source": [[20, "source"], [106, "source"]], "feeder": [[20, "feeder"], [106, "feeder"]], "CONFIGURATION FILES": [[20, "configuration-files"]], "SUNDEW COMPATIBILITY OPTIONS": [[20, "sundew-compatibility-options"]], "destfn_script