--source
select [conversation_handle], [to_service_me], [from_service_name], try_cast([message_body] as xml]), [transmission_status] from sys.transmission_queue;

select [conversation_handle], [state_desc], [far_service] from sys.conversation_endpoints;

select [state_desc], [login_state], [login_time], [principal_name], [remote_user_name] from sys.dm_broker_connections;

select * from sys.service_broker_endpoints;

--target
use msdb;
go
select * from sys.transmission_queue;

use [имя базы];
go
select [conversation_handle], [state_desc], [far_service] from sys.conversation_endpoints;

select * from sys.routes

select [service_broker_guid] from sys.databases where [database_id] = db_id();
select [name], [remote_service_name], [broker_instance], [address] from sys.routes;
select top (1)
      ce.[conversation_handle], 
      ce.[state],
      ce.[far_broker_instance],
      ce.[security_timestamp],
      tq.[from_service_name],
      ce.[far_service],
      cast(tq.[message_body] as xml) as [msg],
      tq.[transmission_status]
from sys.conversation_endpoints ce
    left join sys.transmission_queue tq on tq.[conversation_handle] = ce.[conversation_handle]
order by ce.[send_sequence] desc;

select * from sys.database_permissions where grantee_principal_id = 0 and class = 17;

create or alter proc usp_target
as
declare @h uniqueidentifier, @mt sysname, @mb varbinary(max);
while 1 =1 begin
       begin tran;
       waitfor (
           receive top(1) @h = conversation_handle, @mt = message_type_name, @mb = message_body from [target_queue]
       ), timeout 1000;
       
       if @@rowcount =0 begin
             rollback tran;
             break;
       end;

       if @mt = 'DEFAULT'
            exec some_business_logic_proc @mb;
       else
            exec some_handling_message_proc @mt, @mb;

       end conversation @h;
       commit;
end;