Skip to main content

This content is closed to future replies and is no longer being maintained or updated.
Links may no longer function. If you have a similar request, please write a new post.

Question

 Apoorv Verma (ApoorvV4)
Cognizant

Cognizant
IN
ApoorvV4 Member since 2016 1 post
Cognizant
Posted: Aug 6, 2021
Last activity: Aug 6, 2021
Posted: 6 Aug 2021 4:06 EDT
Last activity: 6 Aug 2021 7:35 EDT
Closed

Notification queue processors fail with exceptions

Hi everyone,

I would like to know is there any solution for the below problem:

pyProcessNotification queue processor is unable to send notification and fails with exception while trying to send notification from OOTB pxNotify activity.

ERROR MESSAGE:

Show More

Hi everyone,

I would like to know is there any solution for the below problem:

pyProcessNotification queue processor is unable to send notification and fails with exception while trying to send notification from OOTB pxNotify activity.

ERROR MESSAGE:

<pxException>com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorTransactionFailedException: PRRuntimeException at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorOnlyOnceExecutionStrategy.saveOffsetAndCommit(QueueProcessorOnlyOnceExecutionStrategy.java:190) at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorOnlyOnceExecutionStrategy.after(QueueProcessorOnlyOnceExecutionStrategy.java:150) at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.IQueueProcessorExecutionStrategy.execute(IQueueProcessorExecutionStrategy.java:28) at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataFlowFactory$1$1.onNext(QueueProcessorDataFlowFactory.java:89) at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorDataFlowFactory$1$1.onNext(QueueProcessorDataFlowFactory.java:78) at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onNext(DataFlowStage.java:449) at com.pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onNext(DataFlowStage.java:382) at com.pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor$2.process(DataFlowExecutor.java:325) at com.pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor.runEventLoop(DataFlowExecutor.java:216) at com.pega.dsm.dnode.api.dataflow.DataFlow$2.emit(DataFlow.java:327) at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:59) at com.pega.dsm.dnode.impl.dataflow.task.strategy.ExecutionStrategy.executeDataFlow(ExecutionStrategy.java:124) at com.pega.dsm.dnode.impl.dataflow.task.strategy.MultiplePartitionExecution.executePartitions(MultiplePartitionExecution.java:87) at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable$1.run(ExecutePartitionsRunnable.java:64) at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable$1.run(ExecutePartitionsRunnable.java:56) at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67) at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContextInternal(ServiceHelper.java:301) at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContext(ServiceHelper.java:146) at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable.call(ExecutePartitionsRunnable.java:56) at com.pega.dsm.dnode.impl.dataflow.service.run.ExecutePartitionsRunnable.call(ExecutePartitionsRunnable.java:33) at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108) at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41) at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:77) at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:59) at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:56) at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67) at com.pega.dsm.dnode.impl.prpc.PrpcThreadFactory$PrpcThread.run(PrpcThreadFactory.java:124) Caused by: com.pega.pegarules.pub.database.DatabaseException: A commit cannot be performed because a deferred save of an instance of class Data-Corr-Email failed: code: &lt;none&gt; SQLState: &lt;none&gt; Message: &lt;none&gt; From: (BL53BP39FU5TJ9PVHCSHOL84GGMLS49U3A) at com.pega.pegarules.data.internal.access.DatabaseImpl.failIfBadDeferredOperation(DatabaseImpl.java:2288) at com.pega.pegarules.data.internal.access.DatabaseImpl.commit(DatabaseImpl.java:2130) at com.pega.pegarules.data.internal.access.DatabaseImpl.commit(DatabaseImpl.java:2099) at com.pega.dsm.dnode.impl.dataflow.asyncexecutor.QueueProcessorOnlyOnceExecutionStrategy.saveOffsetAndCommit(QueueProcessorOnlyOnceExecutionStrategy.java:184) ... 28 more </pxException>

Thanks in advance.

Show Less
***Edited by Moderator: Pooja Gadige to change content format from Discussion to Question, add platform capability tag***
To see attachments, please log in.
Pega Platform 8.4.3
System Administration

We'd prefer it if you saw us at our best.

Pega Collaboration Center has detected you are using a browser which may prevent you from experiencing the site as intended. To improve your experience, please update your browser.

Close Deprecation Notice