CometD.NET is an implementation of the Bayeux client protocol in .NET. The source code is converted from the java source code of cometd-2.6.0 found at http://cometd.org/.
+ CometD.NET - The Bayeux client library in .NET
|_ Bayeux - The Bayeux specification
|_ Client - The C# Bayeux client implementation
|_ Common - Classes from the java cometd-common directory
+ Salesforce.StreamingAPI - An example demonstrates how to use CometD.NET library
to work against a Bayeux server as Salesforce Streaming API
This project was built on Visual Studio 2010 with NuGet Package Manager. It is set to compile with .NET Framework 3.5 with 2 external libraries: log4net and Newtonsoft.Json.
The CometD.NET client only work with a Bayeux (CometD) server to connect to. You can use your installed CometD server (download from http://cometd.org/), or you can use an existing Bayeux server like Salesforce Streaming API.
Usage of this library is basically the same as in the java-client (http://cometd.org/documentation/cometd-java/client), example:
class Program
{
static void OnMessageReceived(IClientSessionChannel channel, IMessage message, BayeuxClient client)
{
// Handles the message
Console.WriteLine(message);
}
static void Main(string[] args)
{
// Initializes a new BayeuxClient
string url = "http://localhost:8080/cometd";
var options = new Dictionary<string, object>(StringComparer.OrdinalIgnoreCase)
{
// CometD server socket timeout during connection: 2 minutes
{ ClientTransport.MaxNetworkDelayOption, 120000 }
};
using ( BayeuxClient client = new BayeuxClient(url, new LongPollingTransport(options)) )
{
// Connects to the Bayeux server
if (client.Handshake(null, 30000)) // Handshake timeout: 30 seconds
{
// Subscribes to channels
IClientSessionChannel channel = client.GetChannel("/service/echo");
channel.Subscribe( new CallbackMessageListener<BayeuxClient>(OnMessageReceived, client) );
// Publishes to channels
var data = new Dictionary<string, string>()
{
{ "bar", "baz" }
};
channel.Publish(data);
Thread.Sleep(120000);
// Disconnects
client.Disconnect(30000);
}
}
}
}The example: Salesforce.StreamingAPI demonstrates how a streaming client works against the Salesforce Streaming API.
You need at least a Salesforce Developer account (registered at http://www.developerforce.com/events/regular/registration.php), or Enterprise, or Unlimited,.. account that support Salesforce Streaming API.
Then, you should use the Workbench tool to create 2 new Push-Topics:
"AllLeads" => "Select Id, Name, Company, Phone, MobilePhone, LeadSource From Lead" "AllOpportunities" => "Select Id, Name, LeadSource, StageName, Type From Opportunity"
- Refer to: http://www.salesforce.com/us/developer/docs/api_streaming/Content/code_sample_java_prereqs.htm for more information.
Updates your Salesforce account information (username, password) into the configuration file: Salesforce.StreamingAPI\App.config
- You should add your Internet IP into Salesforce trusted IP ranges (Setup -> Administration Setup -> Security Controls -> Network Access) to make your password works with this sample.
Finally, builds and runs the example, then watches the Salesforce.StreamingAPI\bin\Debug\*.log files (TopicMessages, ApiClient)
to see all pushed messages that was received from your Salesforce Streaming API.