Configuring Agent Broker

Agent broker handles WSO2 Common Events, It can be used to publish and receive events over Thrift using TCP, SSL, HTTP, and HTTPS, and it can also receive JSON events via HTTP and HTTPS.

WSO2 Complex Event Processor is shipped with an Agent Broker which will be used to receive fired events and handover them to CEP using Local Transport. From CEP we can send output events to any other Agent Server using Thrift over TCP, SSL, HTTP, or HTTPS.

tcp port	: 7611
ssl port	: 7711
http port	: 9763
https port	: 9443

Configuring through User Interface

1. Sign In. Enter your user name and password to log on to the Complex Event Processor Management Console.
   
   
   
   
2. Click on "Configure" section of the left panel 
   
   
   
   
3. Then click on "Add" menu item under "Broker" Menu
   
   
   
   You will get a page with header "Create a New Broker" and here you can configure new broker configurations
   
   

4. Enter the following details in the form to create an Agent broker
   
   

   Broker Name	 : agentBroker
   Broker Type	 : agent
   Receiver URL	 : tcp://localhost:7611 (Here we assume you started an Agent Server at 7611 to have this URL)
   Authenticator URL: ssl://localhost:7711
   User Name	 : admin
   Password	 : admin

   Note

   For secure data transfer use ssl or https for both Receiver URL and  Authenticator URL of the Agent Broker. In the normal case Authenticator URL can be of ssl or https and Receiver URL can be either of tcp or http.

   

   Once you click on the "Add Broker" button, you will be directed to the Available Brokers page.

5. Available Brokers page allows you to view the broker configurations by clicking on the broker name and delete brokers by clicking on delete button.

   

Configuring through broker-manager-config.xml

Broker management configuration can be provided via broker-manager-config.xml. These configurations will be loaded at server start-up.

1. Open broker-manager-config.xml which is at <CEP_HOME>/repository/conf

2. Enter the following Agent broker configurations inside the "brokerManagerConfiguration" element as below

   <brokerManagerConfiguration>
   	..
   	<brokerConfiguraton name="agentBroker" type="agent">
   		<property name="receiverURL">tcp://localhost:7611</property>
   		<property name="authenticatorURL">ssl://localhost:7711</property>
   		<property name="username">admin</property>
   		<property name="password">admin</property>
   	</brokerConfiguraton>
   	..
   	..
   </brokerManagerConfiguration>

Configuring topics for Agent broker

The topic used when using agent broker will look like : <stream name>/<version>

E.g.         org.wso2.phone.retail.store/1.2.0

Input/Output mapping supported by Agent Broker

Agent broker can be configured with Tuple input mapping, and Tuple output mapping of a query.