|
132
|
1 /*******************************************************************************
|
|
|
2
|
|
|
3 copyright: Copyright (c) 2004 Kris Bell. All rights reserved
|
|
|
4
|
|
|
5 license: BSD style: $(LICENSE)
|
|
|
6
|
|
|
7 version: July 2004: Initial release
|
|
|
8
|
|
|
9 author: Kris
|
|
|
10
|
|
|
11 *******************************************************************************/
|
|
|
12
|
|
|
13 module tango.net.cluster.NetworkAlert;
|
|
|
14
|
|
|
15 private import tango.net.cluster.NetworkClient;
|
|
|
16
|
|
|
17 /*******************************************************************************
|
|
|
18
|
|
|
19 *******************************************************************************/
|
|
|
20
|
|
|
21 class NetworkAlert : NetworkClient
|
|
|
22 {
|
|
|
23 /***********************************************************************
|
|
|
24
|
|
|
25 Construct a NetworkAlert gateway on the provided QOS cluster
|
|
|
26 for the specified channel. Each subsequent alert will take
|
|
|
27 place over the given channel.
|
|
|
28
|
|
|
29 ***********************************************************************/
|
|
|
30
|
|
|
31 this (ICluster cluster, char[] channel)
|
|
|
32 {
|
|
|
33 super (cluster, channel);
|
|
|
34 }
|
|
|
35
|
|
|
36 /***********************************************************************
|
|
|
37
|
|
|
38 ***********************************************************************/
|
|
|
39
|
|
|
40 IConsumer createConsumer (ChannelListener listener)
|
|
|
41 {
|
|
|
42 return channel.createBulletinConsumer (listener);
|
|
|
43 }
|
|
|
44
|
|
|
45 /***********************************************************************
|
|
|
46
|
|
|
47 ***********************************************************************/
|
|
|
48
|
|
|
49 void broadcast (IMessage payload = null)
|
|
|
50 {
|
|
|
51 channel.broadcast (payload);
|
|
|
52 }
|
|
|
53 }
|
|
|
54
|
