Accessor

Undocumented in source.

class Accessor (

T

) {

Subscriber sub;

MqttClient pub;

QoSLevel qos;

Duration waitTime;

size_t maxWaitResponses;

void publish(string topic, V val, QoSLevel q);

RMISkeleton!T skeleton;

void receive(string t, BusData msg);

this(T serv, string uniqName);

Broadcaster getBroadcaster(string bus);

void subscribe(string bus, void delegate(string, const(ubyte)[]) dlg);

void subscribe(string bus, void delegate(string, Json) dlg);

void subscribe(string bus, void delegate(string, BusData bm) dlg);

RMIStub!X getClient(string uniqName);

void connect();

}

Constructors

this this(T serv, string uniqName): Undocumented in source.

Members

Classes

BCaster class BCaster: Undocumented in source.
CliCom class CliCom: Undocumented in source.

Functions

connect void connect(): Undocumented in source. Be warned that the author may not have intended to support it.
getBroadcaster Broadcaster getBroadcaster(string bus): Undocumented in source. Be warned that the author may not have intended to support it.
getClient RMIStub!X getClient(string uniqName): Undocumented in source. Be warned that the author may not have intended to support it.
publish void publish(string topic, V val, QoSLevel q): Undocumented in source. Be warned that the author may not have intended to support it.
receive void receive(string t, BusData msg): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe void subscribe(string bus, void delegate(string, const(ubyte)[]) dlg): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe void subscribe(string bus, void delegate(string, Json) dlg): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe void subscribe(string bus, void delegate(string, BusData bm) dlg): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

maxWaitResponses size_t maxWaitResponses;: Undocumented in source.
name string name;: Undocumented in source.
pub MqttClient pub;: Undocumented in source.
qos QoSLevel qos;: Undocumented in source.
skeleton RMISkeleton!T skeleton;: Undocumented in source.
sub Subscriber sub;: Undocumented in source.
waitTime Duration waitTime;: Undocumented in source.

Meta

Source

See Implementation

drmi mqtt accessor classes

Accessor

functions

cliName

interfaces

Broadcaster

manifest constants