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:
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: <none> SQLState: <none> Message: <none>
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.