diff options
Diffstat (limited to 'src/backend/executor/tqueue.c')
| -rw-r--r-- | src/backend/executor/tqueue.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/backend/executor/tqueue.c b/src/backend/executor/tqueue.c index d0edf4e5595..67143d33da6 100644 --- a/src/backend/executor/tqueue.c +++ b/src/backend/executor/tqueue.c @@ -66,7 +66,9 @@ tqueueStartupReceiver(DestReceiver *self, int operation, TupleDesc typeinfo) static void tqueueShutdownReceiver(DestReceiver *self) { - /* do nothing */ + TQueueDestReceiver *tqueue = (TQueueDestReceiver *) self; + + shm_mq_detach(shm_mq_get_queue(tqueue->handle)); } /* |