-- Включаем Service Broker
-- alter database db2_log set enable_broker with rollback immediate; 

use DB2_LOG
go

if exists (select 1 from sysobjects where id = object_id('SendLogMessage'         ) and type in ('P','PC')) drop procedure SendLogMessage
if exists (select 1 from sysobjects where id = object_id('AsyncLogQueueActivation') and type in ('P','PC')) drop procedure AsyncLogQueueActivation
if exists (select 1 from sysobjects where id = object_id('XmlMessageToTable'      ) and type in ('P','PC')) drop procedure XmlMessageToTable
if exists (select 1 from sysobjects where id = object_id('SimpleAuditData'        ) and type in ('U'     )) drop table SimpleAuditData
if exists (select 1 from sys.services                  where name = 'AsyncLogService'    ) drop service AsyncLogService
if exists (select 1 from sys.service_queues            where name = 'AsyncLogQueue'      ) drop queue AsyncLogQueue;
if exists(select * from sys.server_event_notifications where name = 'asyncLogEventNotify') drop event notification asyncLogEventNotify on server
-------------------------------------------------
go

-- Создаем очередь и сервисы

if object_id('AsyncLogQueueActivation', 'P') is null
 exec('create procedure AsyncLogQueueActivation as begin set nocount on; end;');
go

create queue AsyncLogQueue with
 status = on,
 retention = off,
 activation (status = on, procedure_name = AsyncLogQueueActivation, max_queue_readers = 5, execute as owner),
 poison_message_handling (status = on);
go

create service AsyncLogService authorization dbo  
on queue AsyncLogQueue (
    [http://schemas.microsoft.com/SQL/Notifications/PostEventNotification]
);

go
create table SimpleAuditData
(
 ad_id         int identity,
 ad_OccurredAt datetime not null,
 ad_Login       sysname,
 ad_Application nvarchar(128),
 ad_Host        nvarchar(128),
 ad_ShortText   nvarchar(128),
 ad_LongText    nvarchar(4000),
 Stamp          timestamp,
 constraint PK_SimpleAuditData primary key (ad_id)
);
go

-- ХП которая разбирает XML и пишет его в таблицу
create procedure XmlMessageToTable @message xml
as
begin
    with s as
    (
            select
              n.value('EventType[1]'       , 'sysname'        ) as EventType
            , n.value('PostTime[1]'        , 'datetime'       ) as PostTime
            , n.value('TextData[1]'        , 'sysname'        ) as TextData
            , n.value('BinaryData[1]'      , 'varbinary(8000)') as BinaryData
            , n.value('DatabaseID[1]'      , 'int'            ) as DatabaseID
            , n.value('DatabaseName[1]'    , 'sysname'        ) as DatabaseName
            , n.value('ApplicationName[1]' , 'sysname'        ) as ApplicationName
            , n.value('HostName[1]'        , 'sysname'        ) as HostName
            , n.value('SessionLoginName[1]', 'sysname'        ) as SessionLoginName
            from
            @message.nodes('/EVENT_INSTANCE') x(n)
    )
    insert into SimpleAuditData
    (ad_OccurredAt, ad_Login, ad_Application, ad_Host, ad_ShortText, ad_LongText)
    select
        s.PostTime, s.SessionLoginName, s.ApplicationName, s.HostName, s.TextData, cast(s.BinaryData as nvarchar(4000))
    from s 
    --where DatabaseID = db_id();
end

-- Процедура которая будет принимать сообщения и обрабатывать их
go
alter procedure AsyncLogQueueActivation with execute as owner
as
begin
    set nocount on;

    declare @handle uniqueidentifier;
    declare @message xml;
    declare @message_type sysname;
 
    while (1=1)
    begin
        begin transaction;
 
            waitfor
            (
              receive top (1)
                @handle = conversation_handle,
                @message =  CAST(message_body AS XML),
                @message_type = message_type_name
              from AsyncLogQueue
            ), timeout 500;
 
            if (@@rowcount = 0)
            begin
              rollback transaction;
              print 'Error - нет данных в очереди'
              break;
            end
            if @message_type = N'http://schemas.microsoft.com/SQL/Notifications/EventNotification'
            begin
                exec XmlMessageToTable @message
            end
            else if @message_type = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
            begin
                end conversation @handle with cleanup;
            end
            else if @message_type = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
            begin
                --TODO
                --log errors
                end conversation @handle with cleanup;
            end 
        commit transaction;
    end
end
go

-- привязываем пользовательское событие к службе
create event notification asyncLogEventNotify
    on server
    for USERCONFIGURABLE_0 -- event_id = 82
    to service 'AsyncLogService', 'current database';
go

-- Процедура общего вида, с помощью которой можно отправлять сообщения
go
create procedure SendLogMessage @logMsg nvarchar(128), @logData nvarchar(1024)
as
begin
    set nocount on;
    -- sp_trace_generateevent 
    --      [     @eventid  = ]  event_id   
    --      [ , [ @userinfo = ] 'user_info' ]  
    --      [ , [ @userdata = ]  user_data  ]  
    -- event_id - numbers from 82 through 91
    declare @b varbinary(8000) = cast(@logData as varbinary(8000));
    exec sp_trace_generateevent 82, @logMsg, @b;
end
go


exec  SendLogMessage 'message1', 'data1'
exec  SendLogMessage 'message2', 'data2'
exec  SendLogMessage 'message3', 'data3'
exec  SendLogMessage 'message4', 'data4'
waitfor delay '00:00:01'
select * from SimpleAuditData

create procedure log.spLogSimple 
     @logProc nvarchar(255)
   , @logMsg  nvarchar(255)
   , @logData nvarchar(2048) = null
as
begin
    --print 'call log.spLogSimple'
    declare @messageBody xml =
    (
         select
            @logProc as LogProc  
          , @logMsg  as LogMsg  
          , @logData as LogData  
          , db_name() as LogDb
          , getdate() as LogDateTime
        for xml raw  ('AsyncLogMessageSimple'), elements
    ) 
    --print cast(@messageBody as nvarchar(4000))

    -- передаем в событие
    declare @a nvarchar(128) = 'AsyncLogMessageSimple'
    declare @b varbinary(8000) = cast(@messageBody as varbinary(8000));
    exec sp_trace_generateevent 82, @a, @b;

    --print 'finish log.spLogSimple'
end

create procedure log.AsyncLogQueueProcessing with execute as owner
as
begin
    set nocount on;
    SET ARITHABORT OFF;
    set QUERY_GOVERNOR_COST_LIMIT 0;

    ...
    while (1=1)
    begin
        -- begin tran
        waitfor
        (
          receive top (1)
              @handle     = conversation_handle
            , @msgBody    = cast( message_body as xml)
            , @msgType   = message_type_name
          from AsyncLogQueue
        ), timeout 500;
 
        if (@@rowcount = 0)
        begin
            print '@@rowcount = 0, нет данных в очереди, выходим'           
            break;
        end
        ...
            exec log.XmlEventMessageProcessing @msgBody
 
    end
end
---------------
create procedure log.XmlEventMessageProcessing @message xml with execute as owner
as
begin
    ....
    insert into log.AppLog
    ....
end

use master
go
if exists (select 1 from sys.databases where name='db_log')
    drop database db_log

if exists (select 1 from sys.databases where name='db_task')
    drop database db_task

go


if exists (select 1 from master.sys.server_principals where name = 'login_db_owner')
    drop login login_db_owner
go

if exists (select * from master.sys.server_principals where name = 'login_task')
    drop login login_task
go

if exists (select * from master.sys.server_principals where name = 'login_log')
    drop login login_log
go



-------------------------------------------------------------------

create database db_log
go
create database db_task
go

create login login_db_owner with password = 'login_db_owner'
go
create login login_task with password = 'login_task'
go
create login login_log with password = 'login_log'
go

-- собственник баз - login_db_owner

alter authorization on database::db_log to login_db_owner
go
alter authorization on database::db_task to login_db_owner
go


-- логину login_log даем возможность вызывать EVENT-ы
use master
go
grant alter trace to login_log
go

-----------------
-- пользователи в базах
use db_task
go

create user user_task for login login_task
create user user_log for login login_log
go

alter role db_datareader add member user_task
alter role db_datawriter add member user_task
go
grant exec to user_task
grant exec to user_log
go
-----------------
use db_log
go

create user user_task for login login_task
create user user_log for login login_log
go

alter role db_datareader add member user_log
go
alter role db_datawriter add member user_log
go
grant exec to user_log
go
--------------------------
-- тестовая ХП бизнес логики и обертка над sp_trace_generateevent
use db_task
go
create schema log
go
go
-- вроде как логину login_log (c которым связан пользователь базы user_log) 
-- даны права на sp_trace_generateevent
-- и от его имени запустим ХП
create procedure log.spLogSimple @logMsg  nvarchar(255), @logData nvarchar(2048) = null with execute as 'user_log'
as
begin
    declare @m xml= (select @logMsg  as LogMsg , @logData as LogData for xml raw  ('AsyncLogMessageSimple'), elements) 
    declare @a nvarchar(128) = 'AsyncLogMessageSimple'
    declare @b varbinary(8000) = cast(@m as varbinary(8000));
    exec sp_trace_generateevent 82, @a, @b;
end
go
create procedure SomeTaskProc as
begin
    exec log.spLogSimple 'SomeTaskProc start', 'args1'
    waitfor delay '00:00:01.000'
    exec log.spLogSimple 'SomeTaskProc finish', 'args2'
end
go

--------------
-- база с логами
use db_log
go
create schema log
go
create table log.AppLog(LogDateTime datetime, LogMsg nvarchar(128), LogData nvarchar(2000), Stamp timestamp)
go

go
create procedure log.XmlMsgProcessing @message xml
as
begin

    declare @postTime   datetime        = @message.value('(EVENT_INSTANCE/PostTime)[1]'  , 'datetime'       )
    declare @textData   nvarchar(128)   = @message.value('(EVENT_INSTANCE/TextData)[1]'  , 'sysname'        )
    declare @binaryData varbinary(8000) = @message.value('(EVENT_INSTANCE/BinaryData)[1]', 'varbinary(8000)')

    declare @messageXml xml = cast(cast(@binaryData as nvarchar(4000)) as xml)

    declare @logMsg  nvarchar(128) = @messageXml.value('(AsyncLogMessageSimple/LogMsg)[1]' ,'nvarchar(128)'  )
    declare @logData nvarchar(128) = @messageXml.value('(AsyncLogMessageSimple/LogData)[1]','nvarchar(2000)'  )

    insert into log.AppLog(LogDateTime, LogMsg, LogData)
    select @postTime, @logMsg, @logData
end
go

create procedure log.AsyncLogQueueProcessing with execute as 'user_log'
as
begin

    set nocount on;
    set arithabort off;
    set query_governor_cost_limit 0;

    declare @h uniqueidentifier, @h2 uniqueidentifier, @m xml, @msgType sysname 

    while 1=1 begin
         waitfor (receive top (1) @h = conversation_handle, @m = message_body from log.AsyncLogQueue), timeout 500

         if @@rowcount = 0 begin 
              if @h is not null end conversation @h;
              break;
         end

         --логика обработки сообщения
         if @msgType = N'http://schemas.microsoft.com/SQL/Notifications/EventNotification'
         begin
             exec log.XmlMsgProcessing @m
             end conversation @h with cleanup;
         end
         else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
             end conversation @h with cleanup;
         else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
             end conversation @h with cleanup;
     
         if @h2 <> @h and @h2 is not null end conversation @h2;

         set @h2 = @h;
    end

    -- declare @handle uniqueidentifier;
    -- declare @msgBody xml;
    -- declare @msgBodyStr nvarchar(max);
    -- declare @msgType sysname;
    -- while (1=1)
    -- begin        
    --     waitfor(
    --       receive top (1)
    --           @handle  = conversation_handle
    --         , @msgBody = cast( message_body as xml)
    --         , @msgType = message_type_name
    --       from AsyncLogQueue
    --     ), timeout 500;
    -- 
    --     if (@@rowcount = 0)
    --     begin
    --         print '@@rowcount = 0, нет данных в очереди, выходим'
    --         break;
    --     end
    --      
    --     if @msgType = N'http://schemas.microsoft.com/SQL/Notifications/EventNotification'
    --     begin
    --         exec log.XmlEventMessageProcessing @msgBody
    --         end conversation @handle with cleanup;
    --     end
    --     else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
    --         end conversation @handle with cleanup;
    --     else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
    --         end conversation @handle with cleanup;
    -- 
    -- end
end
go

create queue log.AsyncLogQueue with status = on, retention = off,
 activation (status = on, procedure_name = log.AsyncLogQueueProcessing, max_queue_readers = 5, execute as 'user_log'),
 poison_message_handling (status = on);
go

go
create service AsyncLogService authorization user_log on queue log.AsyncLogQueue ([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification] );
go

drop event notification AsyncLogEventNotify on server
go
create event notification AsyncLogEventNotify on server for USERCONFIGURABLE_0 
    to service 'AsyncLogService', 'current database';
go
---------------------------------------------------------
---------------------------------------------------------
use db_task
go
-- эмитируем вызов хранимки бизнес логики от пользователя user_task
execute as user = 'user_task'

    begin try
        exec SomeTaskProc
    end try
    begin catch
        print 'Error in SomeTaskProc'
        print '@error_procedure = '+  isnull(                error_procedure() ,'null')
        print '@error_line      = '+  isnull(convert(varchar,error_line     ()),'null')
        print '@error_number    = '+  isnull(convert(varchar,error_number   ()),'null')
        print '@error_message   = '+  isnull(                error_message  () ,'null')
        print '@error_severity  = '+  isnull(convert(varchar,error_severity ()),'null')
        print '@error_state     = '+  isnull(convert(varchar,error_state    ()),'null')
    end catch

revert

---------------------------------------------------------
---------------------------------------------------------
use db_log
go
-- пробуем вставить сообщение под user_log и прочитать его
--execute as user = 'login_log'
execute as user = 'user_log'

    begin try
        -- exec db_task.log.spLogSimple 'Test message','some data'

        declare @m xml= (select 'Test message2'  as LogMsg , 'some data2' as LogData for xml raw  ('AsyncLogMessageSimple'), elements) 
        declare @a nvarchar(128) = 'AsyncLogMessageSimple'
        declare @b varbinary(8000) = cast(@m as varbinary(8000));
        exec sp_trace_generateevent 82, @a, @b;

        exec log.AsyncLogQueueProcessing
        select top 20 * from log.AppLog order by Stamp desc
    end try
    begin catch
        print 'Error in db_log'
        print '@error_procedure = '+  isnull(                error_procedure() ,'null')
        print '@error_line      = '+  isnull(convert(varchar,error_line     ()),'null')
        print '@error_number    = '+  isnull(convert(varchar,error_number   ()),'null')
        print '@error_message   = '+  isnull(                error_message  () ,'null')
        print '@error_severity  = '+  isnull(convert(varchar,error_severity ()),'null')
        print '@error_state     = '+  isnull(convert(varchar,error_state    ()),'null')
    end catch

revert

use master
go
if exists (select 1 from sys.databases where name='db_task')
    drop database db_task

go

if exists (select 1 from master.sys.server_principals where name = 'login_db_owner')
    drop login login_db_owner
go

if exists (select * from master.sys.server_principals where name = 'login_task')
    drop login login_task
go

if exists (select * from master.sys.server_principals where name = 'login_trace')
    drop login login_trace
go
use master
go

-------------------------------------------------------------------
create database db_task
go

create login login_db_owner with password = 'login_db_owner'
go
create login login_task with password = 'login_task'
go

---------------------------------------------------------------
-- СЕРТИФИКАТ
-- drop certificate [trace_cert]

-- create certificate [trace_cert] encryption by password = 'some_strong_password' with subject = 'certificate_for_trace_events';

-- backup certificate [trace_cert] to file = 'c:\svn\trace_cert.cer'  with private key   
--  ( file = 'c:\svn\trace_cert.pvk',encryption by password = 'some_strong_password', decryption by password = 'some_strong_password' );

create login login_trace from certificate [trace_cert];
go
use master
go
grant alter trace to login_trace;
go
---------------------------------------------------------------

-- собственник баз - login_db_owner
alter authorization on database::db_task to login_db_owner
go

-----------------
-- пользователи в базах
use db_task
go

create user user_task for login login_task
go

alter role db_datareader add member user_task
alter role db_datawriter add member user_task
go
grant exec to user_task
go

--------------------------
-- тестовая ХП бизнес логики и обертка над sp_trace_generateevent
use db_task
go
create schema log
go

create certificate [trace_cert] from file = 'c:\svn\trace_cert.cer' with private key (file = 'c:\svn\trace_cert.pvk' ,  
        encryption by password = 'some_strong_password'   
        ,decryption by password = 'some_strong_password');

go
create procedure log.spLogSimple @logMsg  nvarchar(255), @logData nvarchar(2048) = null -- with execute as 'user_log'
as
begin
    declare @m xml= (select @logMsg  as LogMsg , @logData as LogData for xml raw  ('AsyncLogMessageSimple'), elements) 
    declare @a nvarchar(128) = 'AsyncLogMessageSimple'
    declare @b varbinary(8000) = cast(@m as varbinary(8000));
    exec sp_trace_generateevent 82, @a, @b;
end
go
add signature to log.spLogSimple by certificate [trace_cert] with password = 'some_strong_password';
go
go
create procedure SomeTaskProc as
begin
    exec log.spLogSimple 'SomeTaskProc start', 'args1'
    waitfor delay '00:00:01.000'
    exec log.spLogSimple 'SomeTaskProc finish', 'args2'
end
go

---------------------------------------------------------
use db_task
go
-- эмитируем вызов хранимки бизнес логики от логина login_task
execute as login = 'login_task'

    begin try
        print 'Current login/user: ['+isnull(SUSER_NAME(), 'null')+']/['+isnull(current_user, 'null')+'], call SomeTaskProc...'
        exec SomeTaskProc
        print 'Ok'
    end try
    begin catch
        print 'Error in SomeTaskProc'
        print '@error_procedure = '+  isnull(                error_procedure() ,'null')
        print '@error_line      = '+  isnull(convert(varchar,error_line     ()),'null')
        print '@error_number    = '+  isnull(convert(varchar,error_number   ()),'null')
        print '@error_message   = '+  isnull(                error_message  () ,'null')
        print '@error_severity  = '+  isnull(convert(varchar,error_severity ()),'null')
        print '@error_state     = '+  isnull(convert(varchar,error_state    ()),'null')
    end catch

revert

conversation_handle	conversation_id	is_initiator	service_contract_id	conversation_group_id	service_id	lifetime	state	state_desc	far_service	far_broker_instance	principal_id	far_principal_id	outbound_session_key_identifier	inbound_session_key_identifier	security_timestamp	dialog_timer	send_sequence	last_send_tran_id	end_dialog_sequence	receive_sequence	receive_sequence_frag	system_sequence	first_out_of_order_sequence	last_out_of_order_sequence	last_out_of_order_frag	is_system	priority
B7B2F36D-72FF-E811-8127-0CC47A70A1C0	A08BFD0B-64C5-4B63-A087-B8E7B9A8F976	0	2	00000000-0000-0000-0000-000000000000	65561	2087-01-01 10:44:50.107	CD	CLOSED	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	11	0	0	-1	0	0	0	5
DEA109ED-95FF-E811-8127-0CC47A70A1C0	172476B0-6464-4DB9-A6CA-434B14087F3F	0	2	00000000-0000-0000-0000-000000000000	65561	2087-01-01 10:44:50.107	CD	CLOSED	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	8	0	0	-1	0	0	0	5
D64E0EF4-A8FF-E811-8127-0CC47A70A1C0	A3A3467B-5E23-4942-A844-827CA59B7B93	0	2	00000000-0000-0000-0000-000000000000	65561	2087-01-01 10:44:50.107	CD	CLOSED	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	4	0	0	-1	0	0	0	5
8C5D3F74-B0FF-E811-8127-0CC47A70A1C0	59930D03-6E20-4EB1-A76E-4C4C554A11D7	0	2	8B5D3F74-B0FF-E811-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.443	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	270110	0	0	-1	0	0	0	5
65D5176F-4500-E911-8127-0CC47A70A1C0	337D1522-475E-4F85-B91D-CF9AA493DF0E	0	2	64D5176F-4500-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	35229	0	0	-1	0	0	0	5
D686F8A0-FD00-E911-8127-0CC47A70A1C0	ACF3043A-465D-44BE-81BB-AEF2F3A098AA	0	2	D586F8A0-FD00-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	49503	0	0	-1	0	0	0	5
548A006E-1701-E911-8127-0CC47A70A1C0	1E5D472B-A2AB-46BF-9B1E-D2809A0B6054	0	2	538A006E-1701-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.443	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	56359	0	0	-1	0	0	0	5
53C289A0-2C01-E911-8127-0CC47A70A1C0	F7773E74-D6F1-44F1-9DC6-8CC624698FA7	0	2	52C289A0-2C01-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	51491	0	0	-1	0	0	0	5
D8AC24B0-3001-E911-8127-0CC47A70A1C0	F548C0BF-B19B-490F-A136-E147B2C018F6	0	2	D7AC24B0-3001-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	76844	0	0	-1	0	0	0	5
4BB85015-3801-E911-8127-0CC47A70A1C0	B23C5BD4-2E68-49D8-8CDB-BD8DC2C0DD05	0	2	4AB85015-3801-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	59348	0	0	-1	0	0	0	5
7A4EEBD8-4801-E911-8127-0CC47A70A1C0	CF68993D-DEEB-4C19-8A99-1343EEF5661B	0	2	794EEBD8-4801-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	47554	0	0	-1	0	0	0	5

conversation_handle	conversation_id	is_initiator	service_contract_id	conversation_group_id	service_id	lifetime	state	state_desc	far_service	far_broker_instance	principal_id	far_principal_id	outbound_session_key_identifier	inbound_session_key_identifier	security_timestamp	dialog_timer	send_sequence	last_send_tran_id	end_dialog_sequence	receive_sequence	receive_sequence_frag	system_sequence	first_out_of_order_sequence	last_out_of_order_sequence	last_out_of_order_frag	is_system	priority
9DC46B29-72FF-E811-8127-0CC47A70A1C0	FFFB9CA6-2C5D-4CA1-BFCE-2BEC0ACE3B98	1	2	00000000-0000-0000-0000-000000000000	2	2087-01-01 10:44:50.107	DO	DISCONNECTED_OUTBOUND	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	4603	0x625CED000000	4603	0	0	0	-1	0	0	1	5
745D3F74-B0FF-E811-8127-0CC47A70A1C0	F548C0BF-B19B-490F-A136-E147B2C018F6	1	2	755D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	76844	0x2A20EF000000	-1	0	0	0	-1	0	0	1	5
775D3F74-B0FF-E811-8127-0CC47A70A1C0	ACF3043A-465D-44BE-81BB-AEF2F3A098AA	1	2	785D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	49503	0xD81EEF000000	-1	0	0	0	-1	0	0	1	5
7A5D3F74-B0FF-E811-8127-0CC47A70A1C0	B23C5BD4-2E68-49D8-8CDB-BD8DC2C0DD05	1	2	7B5D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	59348	0x5A21EF000000	-1	0	0	0	-1	0	0	1	5
7D5D3F74-B0FF-E811-8127-0CC47A70A1C0	F7773E74-D6F1-44F1-9DC6-8CC624698FA7	1	2	7E5D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	51491	0x5D1FEF000000	-1	0	0	0	-1	0	0	1	5
805D3F74-B0FF-E811-8127-0CC47A70A1C0	337D1522-475E-4F85-B91D-CF9AA493DF0E	1	2	815D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	35229	0x821FEF000000	-1	0	0	0	-1	0	0	1	5
835D3F74-B0FF-E811-8127-0CC47A70A1C0	CF68993D-DEEB-4C19-8A99-1343EEF5661B	1	2	845D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	47554	0x1EF7EE000000	-1	0	0	0	-1	0	0	1	5
865D3F74-B0FF-E811-8127-0CC47A70A1C0	59930D03-6E20-4EB1-A76E-4C4C554A11D7	1	2	875D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.443	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	270110	0xA627EF000000	-1	0	0	0	-1	0	0	1	5
895D3F74-B0FF-E811-8127-0CC47A70A1C0	1E5D472B-A2AB-46BF-9B1E-D2809A0B6054	1	2	8A5D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.443	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	56359	0x9E27EF000000	-1	0	0	0	-1	0	0	1	5