Examples

composite Main {
graph
//XMSSource Operator with connections.xml 
//defaulted to ./etc/connections.xml
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream  = XMSSource(){
	param 
		connection: "wbe";
		access: "OutTrading";
}    

//XMSSource operator with fully 
//qualified name of connections.xml
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = XMSSource(){
	param     
		connectionDocument:"/home/streamsuser/connections/XMSconnections.xml";
		connection: "wbe";  
		access: "OutTrading";
}    

//XMSSource Operator with the optional 
//error output port specified 
(stream <int32 id, rstring fname, rstring lname>; 
stream <rstring errorMessage> ErrorStream)  = XMSSource(){
	param                     
		connection: "wbe";
		access: "OutTrading";
}    

//XMSSource operator with the optional 
//initDelay and reconnectionPolicy specified
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = XMSSource(){
	param     
		connection: "wbe"; 
		access: "OutTrading";
		reconnectionPolicy: NoRetry;
		initDelay: 10.0;
}

//XMSSource operator with the optional period 
//and reconnectionPolicy specified
stream <int32 id, rstring fname, rstring lname> 
MyPersonNamesStream = XMSSource(){
	param     
		connection: "wbe"; 
		access: "OutTrading"; 
		reconnectionPolicy: InfiniteRetry;
		period: 1.20;
}
// XMSSource operator with the reconnectionPolicy
//specified as BoundedRetry
stream <int32 id, rstring fname, rstring lname>
MyPersonNamesStream = XMSSource(){
	param     
		connection: "wbe"; 
		access: "OutTrading"; 
		reconnectionPolicy: BoundedRetry;
		reconnectionBound: 2u;
		period: 1.20;
}
}