Listing 1

<s12:Envelope
xmlns:12'http://www.w3.org/2003/05/soap-envelope'
xmlns:wsa='http://schemas.xmlsoap.org/ws/2003/03/addressing'
xmlns:wse='http:// schemas.xmlsoap.org/ws/2004/01/eventing'
xmlns:eri='http://electronicsretailer.com/inventory'>
<s12:Header>
<wsa:Action>
http://schemas.xmlsoap.org/ws/2004/01/eventing/Subscribe
</wsa:Action>
<wsa:To>http://electronicsretailer.com/CBRService</wsa:To>
<wsa:ReplyTo>
<wsa:Address>
http://electronicsretailer.com/inventory
</wsa:Address>
</wsa:ReplyTo>
<wsa:MessageID>
uuid:d7c5276b-de29-4313-b4d4-b3425b200840
</wsa:MessageID>
</s12:Header>
<s12:Body>
<wse:Subscribe>
<wse:NotifyTo>
<wse:Address>http://electronicsretailer.com/inventory/HandleNewProduct.asp
</wse:Address>
<wsa:ReferenceProperties>
<eri:LocalSubscriptionID>1234</eri:LocalSubscriptionID>
</wsa:ReferenceProperties>
<wse:NotifyTo>
<wse:Filter xmlns:er='http://electronicsretailer.com/schemas'>
/s12:Envelope/s12:Body/er:NewProduct
</wse:Filter>
</wse:Subscribe>
</s12:Body>
</s12:Envelope>

Listing 2

Listing 3

<s12:Envelope
xmlns:12'http://www.w3.org/2003/05/soap-envelope'
xmlns:wsa='http://schemas.xmlsoap.org/ws/2003/03/addressing'
xmlns:wse='http://schemas.xmlsoap.org/ws/2004/01/eventing'
xmlns:eri='http://electronicsretailer.com/inventory'
xmlns:er='http://electronicsretailer.com/schemas'>
<s12:Header>
<wsa:Action>
http://electronicsretailer.com/schemas/NewProduct
</wsa:Action>
<wsa:To>http://electronicsretailer.com/inventory</wsa:To>
<eri:LocalSubscriptionID>1234</eri:LocalSubscriptionID>
</s12:Header>
<s12:Body>
<eri:NewProduct>
<eri:ProductID>AC-MP471</eri:ProductID>
<eri:ProductName>
Acme 128MB Portable MP3 Player
</eri:ProductName>
<eri:ProductCategory>MP3 Players</eri:ProductCategory>
<eri:Price>47.56</eri:Price>
</eri:NewProduct>
</s12:Body>
</s12:Envelope>

Listing 4: CBRSubscribe.cs

// CBRSubscribe
//
// This is a command line tool that can be used to subscribe
// and endpoint for notifications from a WS-Eventing based Content-Based Routing
service
//
// Usage: CBRSubscribe <web service for notifications> <filter expression> [CBR
URL]
//
// - the first argument is the address of the endpoint where WS-Eventing
notifications
// (documents matching subscription criteria) should be sent
// - the second argument is the filter expression used for the subscription
// - the third argument is the URL for the content-based routing service itself
//
// For convenience this has been packaged as a standalone command line tool.
// However, most likely you would use the Subscribe function alone in your own C#
// or other .NET programs.

using System;
namespace CBRSubscribe
{
class MainClass
{
[STAThread]
///////////////////////////
/// Main - Acts as simple shell to grab command line arguments
static void Main(string[] args)
{
if (args.Length<3)
{
Console.WriteLine("Usage: CBRSubscribe <web service for
notifications> <filter expression> <CBR URL>");
return;
}
bool result;
result=Subscribe(args[0],args[1],args[2]);
if (result)
Console.WriteLine("Endpoint {0} is successfully subscribed to
documents matching {1} with CBR service
{2}!",args[0],args[1],args[2]);
else
Console.WriteLine("Subscription failed!");

return;
}

/// Subscribe function that does the actual work
/// <param name="notifyAddress">
/// this is the address of the endpoint where notifications should be sent
/// </param>
/// <param name="subscriptionFilter">
/// the XPath expression used to identify the documents of interest
/// </param>
/// <param name="cbrServiceURL">
/// The URL where the Content-Based Routing service is located.
/// </param>
/// <returns>boolean to indicate success or failure</returns>
static bool Subscribe(string notifyAddress,string subscriptionFilter,string
cbrServiceURL)
{
CBRSubscribe.CBRService.Subscribe subscription=new
CBRSubscribe.CBRService.Subscribe();
subscription.NotifyTo=new
CBRSubscribe.CBRService.EndpointReferenceType();
subscription.NotifyTo.Address=new
CBRSubscribe.CBRService.AttributedURI();
subscription.NotifyTo.Address.Value=notifyAddress;
subscription.Filter=new
CBRSubscribe.CBRService.MessagePredicateAssertion();
subscription.Filter.Value=subscriptionFilter;

CBRSubscribe.CBRService.Eventing objEventing=new
CBRSubscribe.CBRService.Eventing(cbrServiceURL);
CBRSubscribe.CBRService.SubscribeResponse subscribeResponse=new
CBRSubscribe.CBRService.SubscribeResponse();
subscribeResponse=objEventing.SubscribeOp(subscription);

// sanity check the subscription results
bool result=true;
if (!subscribeResponse.Id.StartsWith("uuid:"))
result=false;

return result;
}
}
}