Class LoopbackRouter

A message router that always raises MessageReceived when a message is published.

Inheritance
Object
LoopbackRouter
Inherited Members
Namespace: PeerTalk.PubSub
Assembly: PeerTalk.dll
Syntax
public class LoopbackRouter : IMessageRouter, IService
Remarks

The allows the NotificationService to invoke the local subscribtion handlers.

Methods

| Improve this Doc View Source

InterestedPeers(String)

Gets the sequence of peers interested in the topic.

Declaration
public IEnumerable<Peer> InterestedPeers(string topic)
Parameters
Type Name Description
String topic

The topic of interest or null for all topics.
Returns
Type Description
IEnumerable<Peer>

A sequence of Peer that are subsribed to the topic.
| Improve this Doc View Source

JoinTopicAsync(String, CancellationToken)

Indicates that the local peer is interested in the topic.

Declaration
public Task JoinTopicAsync(string topic, CancellationToken cancel)
Parameters
Type Name Description
String topic

The topic of interested.
CancellationToken cancel

Is used to stop the task. When cancelled, the TaskCanceledException is raised.
Returns
Type Description
Task

A task that represents the asynchronous operation.
| Improve this Doc View Source

LeaveTopicAsync(String, CancellationToken)

Indicates that the local peer is no longer interested in the topic.

Declaration
public Task LeaveTopicAsync(string topic, CancellationToken cancel)
Parameters
Type Name Description
String topic

The topic of interested.
CancellationToken cancel

Is used to stop the task. When cancelled, the TaskCanceledException is raised.
Returns
Type Description
Task

A task that represents the asynchronous operation.
| Improve this Doc View Source

PublishAsync(PublishedMessage, CancellationToken)

Sends the message to other peers.

Declaration
public Task PublishAsync(PublishedMessage message, CancellationToken cancel)
Parameters
Type Name Description
PublishedMessage message

The message to send.
CancellationToken cancel

Is used to stop the task. When cancelled, the TaskCanceledException is raised.
Returns
Type Description
Task

A task that represents the asynchronous operation.
| Improve this Doc View Source

StartAsync()

Start the service.

Declaration
public Task StartAsync()
Returns
Type Description
Task
| Improve this Doc View Source

StopAsync()

Stop the service.

Declaration
public Task StopAsync()
Returns
Type Description
Task

Events

| Improve this Doc View Source

MessageReceived

Raised when a new message is received.

Declaration
public event EventHandler<PublishedMessage> MessageReceived
Event Type
Type Description
EventHandler<PublishedMessage>

Implements