Create database databaseA
Go
Alter database databaseA set Enable_Broker
Go

Use databaseA
GO
Create Message Type SenderMessageType validation=NONE 
GO
Create Message Type ReceiverMessageType validation=NONE
GO

Create Contract SampleContract
(
  SenderMessageType  SENT BY INITIATOR,
  ReceiverMessageType   SENT BY TARGET
)

Create Queue InitiatorQueue
 WITH status = ON
 
 Create Service SenderService ON QUEUE InitiatorQueue  (SampleContract) 

 Create Route RouteA
WITH
  SERVICE_NAME = 'ReceiverService',
  BROKER_INSTANCE = '7CCCCBB4-3F03-44F6-B94D-AC6282B4DFAD',
  ADDRESS = 'TCP://10.30.10.53:4022'
GO

select service_broker_guid
 from sys.databases
 where name = 'DatabaseA'

Use master
Go
--1. Create a master key for master database.
Create Master Key Encryption BY Password = '1234qwer@'
--Go
/*2.Create certificate and End Point that support 
     certificate based authentication 
*/
Create Certificate EndPointCertificateA
WITH Subject = 'A.Server.Local',
    START_DATE = '01/01/2017',
    EXPIRY_DATE = '01/01/2020'
ACTIVE FOR BEGIN_DIALOG = ON;
GO

CREATE ENDPOINT ServiceBrokerEndPoint
   STATE=STARTED
   AS TCP (LISTENER_PORT = 4022)
   FOR SERVICE_BROKER 
   (
     AUTHENTICATION = CERTIFICATE EndPointCertificateA,
     ENCRYPTION = SUPPORTED
   );

BACKUP CERTIFICATE EndPointCertificateA 
 TO FILE = 
   'C:\backup\EndPointCertificateA.cer';
GO

Create Certificate EndPointCertificateB
 From FILE = 
 'C:\Backup\EndPointCertificateB.cer';
GO


CREATE LOGIN sbLogin
 FROM CERTIFICATE EndPointCertificateB;
GO

GRANT CONNECT ON ENDPOINT::ServiceBrokerEndPoint To sbLogin
GO

Use DatabaseA
GO
Create Master Key Encryption BY
Password = '1234qwer@'
Go

Create Certificate UserCertificateA
 WITH Subject = 'A.Server.Local',
    START_DATE = '01/01/2018',
    EXPIRY_DATE = '01/01/2020'
ACTIVE FOR BEGIN_DIALOG = ON;
GO

BACKUP CERTIFICATE UserCertificateA TO FILE=
'C:\backup\UserCertificateA.cer';
GO

Create User UserB WITHOUT LOGIN
GO


CREATE CERTIFICATE UserCertificateB
 AUTHORIZATION UserB
 FROM FILE = 'C:\backup\UserCertificateB.cer';
GO

GRANT CONNECT TO UserB;

GRANT SEND ON SERVICE::SenderService To UserB;
GO

CREATE REMOTE SERVICE BINDING ServiceBindingB
 TO SERVICE 'ReceiverService'
 WITH USER = UserB


 /**********Begin a Dialog and Send a Message******************/
Declare @ConversationHandle uniqueidentifier

Begin Transaction
Begin Dialog @ConversationHandle
 From Service SenderService
 To Service 'ReceiverService'
 On Contract SampleContract
 WITH Encryption=off;
SEND 
      ON CONVERSATION @ConversationHandle
      Message Type SenderMessageType
  ('<test>test</test>')
Commit

Create database databaseB
Go
Alter database databaseB set Enable_Broker
Go

Use databaseB
GO
Create Message Type SenderMessageType validation=NONE
Create Message Type ReceiverMessageType validation=NONE

Create Contract SampleContract
(
  SenderMessageType  SENT BY INITIATOR,
  ReceiverMessageType   SENT BY TARGET
)

Create Queue TargetQueue WITH status= ON

Create Service ReceiverService ON QUEUE TargetQueue (SampleContract)

Create Route RouteB
WITH
  SERVICE_NAME = 'SenderService',
  BROKER_INSTANCE='886B2333-B33F-4A07-A16C-82DD193CAD57',
 ADDRESS = 'TCP://10.30.10.205:4022'
GO

Use master
Go
 
--1. Create a master key for master database.
Create Master Key Encryption BY Password = '1234qwer@';
Go
--2.Create certificate and End Point that support certificate based authentication.
Create Certificate EndPointCertificateB
WITH Subject = 'B.Server.Local',
       START_DATE = '01/01/2018',
       EXPIRY_DATE = '01/01/2020'
ACTIVE FOR BEGIN_DIALOG = ON;
GO
CREATE ENDPOINT ServiceBrokerEndPoint
      STATE=STARTED
      AS TCP (LISTENER_PORT = 4022)
      FOR SERVICE_BROKER
      ( 
         AUTHENTICATION = CERTIFICATE EndPointCertificateB,
         ENCRYPTION = SUPPORTED
      );

BACKUP CERTIFICATE EndPointCertificateB TO FILE=
  'C:\Backup\EndPointCertificateB.cer';
GO

Create Certificate EndPointCertificateA
 From FILE = 
 'C:\backup\EndPointCertificateA.cer';
GO

CREATE LOGIN sbLogin
 FROM CERTIFICATE EndPointCertificateA;
GO

GRANT CONNECT ON ENDPOINT::ServiceBrokerEndPoint To sbLogin
GO


Use DatabaseB
GO
Create Master Key Encryption BY
Password = '1234qwer@';
Go

Create Certificate UserCertificateB
 WITH Subject = 'B.Server.Local',
    START_DATE = '01/01/2018',
    EXPIRY_DATE = '01/01/2020'
ACTIVE FOR BEGIN_DIALOG = ON;
GO

BACKUP CERTIFICATE UserCertificateB TO
FILE='C:\backup\UserCertificateB.cer';
GO

Create User UserA WITHOUT LOGIN
GO

CREATE CERTIFICATE UserCertificateA
 AUTHORIZATION UserA
FROM FILE = 'C:\backup\UserCertificateA.cer';
GO

GRANT CONNECT TO UserA;

GRANT SEND ON SERVICE::ReceiverService To UserA;
GO

CREATE REMOTE SERVICE BINDING ServiceBindingA
 TO SERVICE 'SenderService'
 WITH USER = UserA

 select cast(message_body as xml)  from TargetQueue

 /*****Receive the Message and send a message to the ender**********/

Declare @ConversationHandle as uniqueidentifier
Declare @MessageBody as nvarchar(max)
Declare @MessageType as sysname

Begin Transaction
Print 'Started Receiving ';

RECEIVE top (1)
      @MessageType = message_type_name,
      @ConversationHandle = conversation_handle,
    @MessageBody = message_body
FROM TargetQueue;

if @MessageType = 'SenderMessageType'
      Begin
            SEND 
                  ON CONVERSATION @ConversationHandle
                  Message Type ReceiverMessageType
                  ('Message is received')
            END Conversation @ConversationHandle
      END

Commit