有没有办法更改 Nifi 中 PublishJMS 处理器的交付模式?

2024-03-17

​我使用 Nifi PublishJMS 处理器向 IBM MQ 发送消息。消息在 MQ 中具有持久性 = 持久性。我想将其更改为非持久性。 Nifi PublishJms 处理器中是否有属性可以纠正此问题?或者是从MQ端完成的。我无权访问 MQ 服务器,只能检查传递到队列的消息。


在较低级别,MQ 客户端应用程序可以指定以下持久性值:

  • MQPER_PERSISTENCE_AS_PARENT(使用本主题之上的下一个主题的值)
  • MQPER_NOT_PERSISTENT(不言自明)
  • MQPER_PERSISTENT(不言自明)
  • MQPER_PERSISTENCE_AS_TOPIC_DEF(使用该主题的值,主题的默认值是 ASPARENT,所以这就像MQPER_PERSISTENCE_AS_PARENT使用默认值的地方)

如果没有指定任何内容MQPER_PERSISTENCE_AS_TOPIC_DEF是默认值。

在 JMS API 中,您可以使用 URI 属性覆盖它,如下所示:

queue:///theQueueName?persistence=1


财产persistence并且所有 URI 属性都记录在 IBM MQ v8 知识中心页面“在 JMS 应用程序中创建目标 https://www.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.dev.doc/q032240_.htm".

物业名称:坚持

  • -2- 在 send() 调用中指定,或者如果在 send() 调用中未指定,则消息生产者的默认持久性。
  • -1- 由 IBM MQ 队列或主题的 DefPersistence 属性指定。
  • 1- 非持久。
  • 2- 执着的。
  • 3- 相当于 IBM MQ JMS 管理工具中使用的 PERSISTENCE 属性的 HIGH 值。对于这一点的解释 值,参见JMS持久化 消息 https://www.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.dev.doc/q032380_.htm?view=kc#q032380_.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

有没有办法更改 Nifi 中 PublishJMS 处理器的交付模式? 的相关文章

随机推荐

  • 使用共享图像库使用托管磁盘的 Terraform Azure VM

    类似问题 Terraform 计划在重新运行共享图像库中存储的自定义图像时销毁并替换 Azure VM https stackoverflow com questions 64050815 terraform plan destroying
  • BrowserRouter 与打字稿反应

    我在 Reactjs 类型脚本中有简单的应用程序 我正在尝试使用react router dom 中的BrowserRouter 这是我的代码 import as React from react import Popular from p
  • 删除其他用户正在访问的数据库?

    我尝试从 PgAdmin 3 删除数据库 但收到以下错误消息 ERROR can t delete current database SQL state 55006 我怎样才能强制删除 修复这个数据库的这个错误 这个帖子 http www
  • 逐行读取文件而不是将文件读入内存

    我在逐行读取文件而不是将文件读入内存时遇到一些麻烦 截至目前 我正在将文件读入内存 并且运行完美 但是 如果我尝试逐行读取文件 当我输入 print B 时 我只会得到零 我的问题是 有人有一个好的命令可以在 python 中逐行读取文件吗
  • 编辑/etc/kubernetes/manifests/kube-apiserver.yaml后kube-apiserver如何重启

    我使用安装了 kuberneteskubeadm 为了启用基本身份验证 我添加了 basic auth file etc kubernetes user password txt in my etc kubernetes manifests
  • Jquery/HTML5/Ajax上传进度条?

    我正在开发一个简单的 S3 上传器 让它执行并完成我需要做的事情 但是 我想知道是否有一个易于创建上传进度条的方法 在浏览器的底部 有一条浏览器消息 上面写着 正在上传 是否有任何人知道有关该消息的文章以显示加载栏 理想情况下 该变量将传递
  • 在 SymPy 中,为什么我的解决方案(nonlinsolve)返回错误的答案?

    我有一个由 3 个方程组成的系统 我想找到以下交线或零斜线的解dx dy from sympy import x y z symbols x y z dx x x 3 3 z y dy y 2 0 1 z dz 0 xy nullcline
  • 如何检查 Makefile 中是否存在文件以便将其删除?

    在我的干净部分Makefile我试图在永久删除之前检查该文件是否存在 我使用此代码但收到错误 它出什么问题了 if a myApp then rm myApp fi 我收到此错误消息 if a myApp bin sh Syntax err
  • 独立的共享库

    我需要创建一个共享库 其自身的依赖项 包括 libc libstdc 必须静态链接到它以生成独立的二进制文件 我尝试这样做 g c fpic o foo o foo cpp g static shared o foo so foo o 失败
  • symfony 中的 Doctrine 可搜索行为与 Zend Lucene

    我需要在2个表中搜索关键字 简单的事情 我尚未决定使用其中之一吗 有什么建议吗 Thanks 正如 cuhuak 提到的 Lucene 是全文搜索 由于它是用 Java 编写的 因此您还需要一个 Java 服务器 例如 Tomcat 如果您
  • Swift 中 SQLite 项目中的 UnsafePointer 问题

    我们在 iOS 和 Swift 中实现 SQLite 不使用包装器或 Objective C 桥接 一切工作正常 除了执行查询和提取结果时 问题在于UnsafePointer
  • Nodejs回调机制——哪个线程处理回调?

    我是 NodeJS 的新手 对 Node js 的单实例模型感到好奇 在一个简单的nodeJs应用程序中 当使用回调异步处理某些阻塞操作时 运行nodeJs的主线程是否也会处理回调 如果请求是从数据库中获取一些数据 并且有 100 个并发用
  • 如何处理 REST 调用、数据持久化、同步和观察 ContentProvider

    我知道这个问题已经被问了太多次了 但我认为我想要解决的问题有点不同 也许更复杂 我将开发一个使用RESTful Web 服务并需要具备以下要求 该应用程序应该以列表和详细方式显示一些书籍及其作者和编辑 该应用程序还应该允许搜索书籍 书籍 作
  • Android - 为什么对地理围栏使用待处理意图

    我刚刚完成了 Android 上的地理围栏教程 http developer android com training location geofencing html http developer android com training
  • Swift3 的所有 UIView 中都有不同的字体,每个都有本地化

    我想使用不同的字体直至每种语言 例如 英语中的 roboto 法语中的 openSans 本土化 arrayOfTitle NSLocalizedString comment comment 0 NSLocalizedString prof
  • 如何使用c++中的sort函数对二维数组进行排序?

    我有一个n x m我需要排序的数组 但是 我只需要查看每个一维数组的第一个值即可对较大的数组进行排序 例如 考虑以下二维数组 1 2 4 4 3 5 我不关心子数组中的第二个值 我只需要查看子数组的第一个值即可对其进行排序 所以 我只会看1
  • 在文件中执行 pgsql 命令的 Shell 脚本

    我正在尝试自动化一组创建模板数据库的过程 我有一组文件 file1 file2 fileN 每个文件都包含创建 TEMPLATE 数据库所需的一组 pgsql 命令 文件 创建的 template1 sql 的内容大致如下 CREATE D
  • 如何成为 iOS 的 MDM 供应商

    对此做了很多研究 看到了几个意见 很少有人说我需要苹果企业帐户 也很少有人说我不需要 拥有 MAC 服务器会有帮助吗 我是否需要拥有企业帐户才能成为 MDM 供应商 任何指点都会很棒 我看到了MDM提供的技术业务文档 但它没有解释任何关于服
  • 我想在单击每个树节点时将信息添加到 jpanel jscrollpane 中

    我想在单击每个树节点时将要添加的信息添加到 jpanel jscrollpane 中 请 1 我想控制在Tree java中选择的树节点的状态 其中Frame java 树 java package pms import java awt
  • 有没有办法更改 Nifi 中 PublishJMS 处理器的交付模式?

    我使用 Nifi PublishJMS 处理器向 IBM MQ 发送消息 消息在 MQ 中具有持久性 持久性 我想将其更改为非持久性 Nifi PublishJms 处理器中是否有属性可以纠正此问题 或者是从MQ端完成的 我无权访问 MQ