wn/pubsubclient
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

A *working* example this time!

Browse Source
This commit is contained in:
Mark Cheverton 2014-01-20 22:50:10 +00:00
parent 1113695f4a
commit 93b9a4e2d1
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
PubSubClient/examples/mqtt_stream/mqtt_stream.ino
View File

@ -19,20 +19,23 @@ byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED };
byte server[] = { 172, 16, 0, 2 }; byte server[] = { 172, 16, 0, 2 };
byte ip[] = { 172, 16, 0, 100 }; byte ip[] = { 172, 16, 0, 100 };
SRAM sram(SRAM_CS_PIN, SRAM_1024); SRAM sram(4, SRAM_1024);
void callback(char* topic, byte* payload, unsigned int length) { void callback(char* topic, byte* payload, unsigned int length) {
sram.seek(1); sram.seek(1);
// do something with the message // do something with the message
myfunctionthattakesastreamargument(&sram); for(uint8_t i=0; i<length; i++) {
Serial.write(sram.read());
}
Serial.println();
// Reset position for the next message to be stored // Reset position for the next message to be stored
sram.seek(1); sram.seek(1);
} }
EthernetClient ethClient; EthernetClient ethClient;
PubSubClient client(server, 1883, callback, ethClient); PubSubClient client(server, 1883, callback, ethClient, &sram);
void setup() void setup()
{ {
@ -44,6 +47,8 @@ void setup()
sram.begin(); sram.begin();
sram.seek(1); sram.seek(1);
Serial.begin(9600);
} }
void loop() void loop()