Repository: camel Updated Branches: refs/heads/master b45652154 -> 0f393b668
[CAMEL-9256] Paho file persistence store should be configurable Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0f393b66 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0f393b66 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0f393b66 Branch: refs/heads/master Commit: 0f393b668ee87961d3f66bf300eb4ffcfb9c49ea Parents: b456521 Author: Henryk Konsek <hekon...@gmail.com> Authored: Mon Oct 26 11:58:47 2015 +0100 Committer: Henryk Konsek <hekon...@gmail.com> Committed: Mon Oct 26 11:58:47 2015 +0100 ---------------------------------------------------------------------- .../camel/component/paho/PahoEndpoint.java | 23 +++++++++++++++++++- 1 file changed, 22 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/0f393b66/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java index bc6ee97..0527306 100644 --- a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java +++ b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java @@ -62,6 +62,8 @@ public class PahoEndpoint extends DefaultEndpoint { private int qos = DEFAULT_QOS; @UriParam(defaultValue = "MEMORY") private PahoPersistence persistence = MEMORY; + @UriParam(description = "Base directory used by file persistence.", defaultValue = "Current directory") + private String filePersistenceDirectory; // Collaboration members @UriParam @@ -114,7 +116,15 @@ public class PahoEndpoint extends DefaultEndpoint { // Resolvers protected MqttClientPersistence resolvePersistence() { - return persistence == MEMORY ? new MemoryPersistence() : new MqttDefaultFilePersistence(); + if (persistence == MEMORY) { + return new MemoryPersistence(); + } else { + if (filePersistenceDirectory != null) { + return new MqttDefaultFilePersistence(filePersistenceDirectory); + } else { + return new MqttDefaultFilePersistence(); + } + } } protected MqttConnectOptions resolveMqttConnectOptions() { @@ -203,6 +213,17 @@ public class PahoEndpoint extends DefaultEndpoint { this.persistence = persistence; } + public String getFilePersistenceDirectory() { + return filePersistenceDirectory; + } + + /** + * Base directory used by the file persistence provider. + */ + public void setFilePersistenceDirectory(String filePersistenceDirectory) { + this.filePersistenceDirectory = filePersistenceDirectory; + } + public MqttClient getClient() { return client; }
