DECLARE @handle UNIQUEIDENTIFIER

DECLARE conv_cur CURSOR FAST_FORWARD FOR SELECT CONVERSATION_HANDLE FROM SYS.CONVERSATION_ENDPOINTS (nolock) WHERE state_desc = 'DISCONNECTED_INBOUND'

OPEN conv_cur;

FETCH NEXT FROM conv_cur INTO @handle;

WHILE @@fetch_status = 0
BEGIN
   END CONVERSATION @handle WITH CLEANUP
   FETCH NEXT FROM conv_cur INTO @handle;
END

CLOSE conv_cur;
DEALLOCATE conv_cur;
GO

DECLARE @t TABLE( AutoID INT IDENTITY, ConversationHandle UNIQUEIDENTIFIER)
        
-- insert the handles of all open conversations to the 
-- memory table
INSERT INTO 
    @t (ConversationHandle)
SELECT top(1000000)
    [conversation_handle] 
FROM
    sys.conversation_endpoints (nolock) 
WHERE 
	state_desc = 'DISCONNECTED_INBOUND'


-- local variables
DECLARE @cnt INT, @max INT, @handle UNIQUEIDENTIFIER
SELECT @cnt = 1, @max = COUNT(*) FROM @t

-- run a loop for each row in the memory table
WHILE @cnt <= @max BEGIN
    -- read the conversation_handle
    SELECT
        @handle = ConversationHandle
    FROM @t WHERE AutoID = @cnt
    
    -- end conversation
    PRINT 'Closing conversation: ' + CAST(@handle AS VARCHAR(50))
    END CONVERSATION @handle WITH CLEANUP
    
    -- increment counter
    SELECT @cnt = @cnt + 1
END

ALTER DATABASE TestDB
SET DISABLE_BROKER

ALTER DATABASE TestDB
SET ENABLE_BROKER

ALTER DATABASE TestDB WITH ERROR_BROKER_CONVERSATIONS

ALTER DATABASE TestDB
SET NEW_BROKER
WITH ROLLBACK IMMEDIATE

ALTER DATABASE SET SINGLE_USER WITH ROLLBACK IMMEDIATE 
GO
ALTER DATABASE TestDB SET NEW_BROKER 
GO
ALTER DATABASE SET MULTI_USER 
GO