Declare @hMessage varchar(255),@msg_id varchar(255) 
Declare @MessageText varchar(8000),@message varchar(8000)
Declare @MessageSubject varchar(8000),@subject varchar(8000)
Declare @Origin varchar (8000), @originator_address varchar(8000)

EXEC master.dbo.xp_findnextmsg @unread_only='true',@msg_id=@hMessage OUT 

WHILE @hMessage IS NOT NULL 
BEGIN

exec master.dbo.xp_readmail
@msg_id=@hMessage,
@message=@MessageText OUT,
@subject=@MessageSubject OUT,
@originator_address=@Origin OUT

IF ((SELECT COUNT(*) FROM forum_users WHERE email = @Origin) = 1)	-- IF email from forum-recognised address
BEGIN 
	IF (CHARINDEX('(ThreadID=', @MessageSubject)>0) 		-- IF email has a thread ID
		BEGIN
		DECLARE @existingID int, @em1 varchar(100), @bdy1 varchar(8000), @sbj1 varchar(500)
		SELECT @existingID=CAST(SUBSTRING(@MessageSubject, (CHARINDEX('=', @MessageSubject)+1), (CHARINDEX(')', @MessageSubject)-(CHARINDEX('=', @MessageSubject)+1))) AS int)
		INSERT INTO forum_posts (body, thread_id) VALUES (@MessageText, @existingID)

									-- Do mailing

		declare em_cursor1 cursor for
			SELECT email FROM forum_users WHERE email_option='yes'
		open em_cursor1
		fetch next from em_cursor1
		into @em1

		while @@FETCH_STATUS=0
		begin
			select @bdy1='New ICNA Forum Post:'+CHAR(13)+CHAR(10)+CHAR(13)+CHAR(10)+@MessageText
			select @sbj1='New ICNA Forum Post (ThreadID='+@existingID+')'
			exec master.dbo.xp_sendmail @em1,@bdy1,@sbj1
			fetch next from em_cursor1
			into @em1
		end
		close em_cursor1
		deallocate em_cursor1

	END
	ELSE								-- IF email has no thread ID
		BEGIN							
		DECLARE @newID int, @em2 varchar(100), @bdy2 varchar(8000), @sbj2 varchar(500)				-- Create a new thread record and use the resulting ID to add a thread_post record
		INSERT INTO forum_threads (subject) VALUES (@MessageSubject)
		SELECT @newID=@@IDENTITY
		INSERT INTO forum_posts (body, thread_id) VALUES (@MessageText, @newID)

									-- Do mailing

		declare em_cursor2 cursor for
			SELECT email FROM forum_users WHERE email_option='yes'
		open em_cursor2
		fetch next from em_cursor2
		into @em2

		while @@FETCH_STATUS=0
		begin
			select @bdy2='New ICNA Forum Post:'+CHAR(13)+CHAR(10)+CHAR(13)+CHAR(10)+@MessageText
			select @sbj2='New ICNA Forum Post (ThreadID='+@newID+')'
			exec master.dbo.xp_sendmail @em2,@bdy2,@sbj2
			fetch next from em_cursor2
			into @em2
		end
		close em_cursor2
		deallocate em_cursor2

	END
END

SET @hMessage = NULL 

EXEC master.dbo.xp_findnextmsg @unread_only='true',@msg_id=@hMessage OUT 
END