diff --git a/src/ioc/rsrv/camessage.c b/src/ioc/rsrv/camessage.c
index b13883b5a..49e2acb86 100644
--- a/src/ioc/rsrv/camessage.c
+++ b/src/ioc/rsrv/camessage.c
@@ -777,6 +777,10 @@ static int read_notify_action ( caHdrLargeArray *mp, void *pPayload, struct clie
     struct channel_in_use *pciu;
     struct event_ext evext;
 
+    if ( INVALID_DB_REQ(mp->m_dataType) ) {
+        return RSRV_ERROR;
+    }
+
     pciu = MPTOPCIU ( mp );
     if ( !pciu ) {
         logBadId ( client, mp, pPayload );
@@ -1889,6 +1893,10 @@ static int event_add_action (caHdrLargeArray *mp, void *pPayload, struct client
     struct channel_in_use *pciu;
     struct event_ext *pevext;
 
+    if ( INVALID_DB_REQ(mp->m_dataType) ) {
+        return RSRV_ERROR;
+    }
+
     pciu = MPTOPCIU ( mp );
     if ( ! pciu ) {
         logBadId ( client, mp, pPayload );