Skip to content

Instantly share code, notes, and snippets.

@aka-z

aka-z/arduino-stomp.ino

Forked from krhoyt/arduino-stomp.ino
Created September 29, 2019 23:52
Show Gist options
  • Save aka-z/060ee7efe705134d22f836892fbaffb3 to your computer and use it in GitHub Desktop.
Save aka-z/060ee7efe705134d22f836892fbaffb3 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. Kevin Hoyt revised this gist May 26, 2014. 1 changed file with 34 additions and 14 deletions.
    48 changes: 34 additions & 14 deletions arduino-stomp.ino
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,12 @@
    #include <YunClient.h>

    // Defines
    #define NEOPIXEL_PIN 8
    // Used for connectivity parameters
    #define ENDPOINT "kaazing.kevinhoyt.com"
    #define LOGIN " "
    #define PASSCODE " "
    #define PORT 61613
    #define TOPIC "/topic/heart"

    // Constants for STOMP
    const int DISCONNECTED = 0;
    @@ -14,11 +19,8 @@ const int SUBSCRIBING = 4;
    const int SUBSCRIBED = 5;
    const int SENDING = 6;
    const int SENT = 7;

    // Constants for application
    const int PORT = 61613;
    const String ENDPOINT = "kaazing.kevinhoyt.com";
    const String TOPIC = "/topic/heart";
    const int DISCONNECTING = 8;
    const int STOP = 9;

    // Global
    int counter;
    @@ -55,7 +57,7 @@ void loop()
    if( state == DISCONNECTED )
    {
    // Connect to server
    if( client.connect( "kaazing.kevinhoyt.com", 61613 ) )
    if( client.connect( ENDPOINT, PORT ) )
    {
    // Set connecting state
    state = CONNECTING;
    @@ -70,7 +72,11 @@ void loop()
    client.println( "CONNECT" );
    client.println( "accept-version:1.2" );
    client.print( "host:" );
    client.println( "kaazing.kevinhoyt.com" );
    client.println( ENDPOINT );
    client.print( "login:" );
    client.println( LOGIN );
    client.print( "passcode:" );
    client.println( PASSCODE );
    client.println();
    client.write( 0x0 );

    @@ -100,30 +106,38 @@ void loop()
    client.print( "destination:" );
    client.println( TOPIC );
    client.println( "content-type:text/plain" );
    // client.print( "content-length:" );
    // client.println( body.length() );
    client.print( "content-length:" );
    client.println( body.length() );
    client.print( "receipt:message-" );
    client.println( counter );
    client.println();
    client.println( body );
    client.print( body );
    client.write( 0x0 );

    state = SENDING;
    Serial.println( "Sending message..." );
    } else if( state == SENT ) {
    body = String( counter );

    client.println( "DISCONNECT" );
    client.print( "receipt:disconnect-" );
    client.println( body );
    client.write( 0x0 );

    state = DISCONNECTING;
    Serial.println( "Disconnecting..." );
    }

    // Incoming data from broker
    if( client.available() > 0 )
    {
    response = client.readStringUntil( 0x0 );

    /*
    Serial.print( "*** Response Start (" );
    Serial.print( response.length() );
    Serial.println( ") ***" );
    Serial.println( response );
    Serial.println( "*** Response End ***" );
    */

    if( response.length() > 0 )
    {
    @@ -150,10 +164,16 @@ void loop()
    state = SUBSCRIBED;
    Serial.println( "Subscribed." );
    } else if( state == SENDING ) {
    state = SUBSCRIBED;
    state = SENT;
    Serial.println( "Sent." );

    delay( 1000 );
    } else if( state == DISCONNECTING ) {
    Serial.println( "Disconnected." );

    client.stop();
    Serial.println( "Connection closed." );
    state = STOP;
    }
    }
    }
  2. Kevin Hoyt renamed this gist May 21, 2014. 1 changed file with 0 additions and 0 deletions.
    0 gistfile1.c → arduino-stomp.ino
    View file
    File renamed without changes.
  3. Kevin Hoyt created this gist May 21, 2014.
    257 changes: 257 additions & 0 deletions gistfile1.c
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,257 @@
    // Libraries
    #include <Bridge.h>
    #include <YunClient.h>

    // Defines
    #define NEOPIXEL_PIN 8

    // Constants for STOMP
    const int DISCONNECTED = 0;
    const int CONNECTING = 1;
    const int CONNECTED = 2;
    const int WAITING = 3;
    const int SUBSCRIBING = 4;
    const int SUBSCRIBED = 5;
    const int SENDING = 6;
    const int SENT = 7;

    // Constants for application
    const int PORT = 61613;
    const String ENDPOINT = "kaazing.kevinhoyt.com";
    const String TOPIC = "/topic/heart";

    // Global
    int counter;
    int state;
    String session;
    YunClient client;

    // Setup
    void setup()
    {
    // Initially disconnected
    state = DISCONNECTED;

    // Serial for debugging
    Serial.begin( 9600 );

    // Start Yun bridge
    // Used for network connectivity
    Bridge.begin();

    // Wait until bridge is open
    while( !Serial );
    }

    // Loop
    void loop()
    {
    int start;
    String body;
    String frame;
    String response;

    // If disconnected
    if( state == DISCONNECTED )
    {
    // Connect to server
    if( client.connect( "kaazing.kevinhoyt.com", 61613 ) )
    {
    // Set connecting state
    state = CONNECTING;
    Serial.println( "Connecting..." );
    } else {
    // Problem connecting
    Serial.println( "Not connected" );
    }
    // Connected to server
    } else if( state == CONNECTING ) {
    // Initiate STOMP connection
    client.println( "CONNECT" );
    client.println( "accept-version:1.2" );
    client.print( "host:" );
    client.println( "kaazing.kevinhoyt.com" );
    client.println();
    client.write( 0x0 );

    // Waiting for response
    Serial.println( "Connect header sent..." );
    state = WAITING;
    // Connected to STOMP broker
    } else if( state == CONNECTED ) {
    // Subscribe to specified destination
    client.println( "SUBSCRIBE" );
    client.print( "id:" );
    client.println( session );
    client.print( "destination:" );
    client.println( TOPIC );
    client.println( "receipt:subscribed" );
    client.println();
    client.write( 0x0 );

    // Subscribing to topic
    Serial.println( "Subscribing to topic..." );
    state = SUBSCRIBING;
    } else if( state == SUBSCRIBED ) {
    counter = counter + 1;
    body = String( counter );

    client.println( "SEND" );
    client.print( "destination:" );
    client.println( TOPIC );
    client.println( "content-type:text/plain" );
    // client.print( "content-length:" );
    // client.println( body.length() );
    client.print( "receipt:message-" );
    client.println( counter );
    client.println();
    client.println( body );
    client.write( 0x0 );

    state = SENDING;
    Serial.println( "Sending message..." );
    }

    // Incoming data from broker
    if( client.available() > 0 )
    {
    response = client.readStringUntil( 0x0 );

    /*
    Serial.print( "*** Response Start (" );
    Serial.print( response.length() );
    Serial.println( ") ***" );
    Serial.println( response );
    Serial.println( "*** Response End ***" );
    */

    if( response.length() > 0 )
    {
    frame = getValue( response, 0, "\n" );

    if( frame == "CONNECTED" )
    {
    // Get session for later reference
    session = getHeader( response, "session" );
    Serial.print( "Session: " );
    Serial.println( session );

    // Set state
    state = CONNECTED;
    Serial.println( "Connected." );
    } else if( frame == "MESSAGE" ) {
    body = getValue( response, 1, "\n\n" );

    Serial.print( "Message: " );
    Serial.println( body );
    } else if( frame == "RECEIPT" ) {
    if( state == SUBSCRIBING )
    {
    state = SUBSCRIBED;
    Serial.println( "Subscribed." );
    } else if( state == SENDING ) {
    state = SUBSCRIBED;
    Serial.println( "Sent." );

    delay( 1000 );
    }
    }
    }

    // Read last null byte
    client.read();
    }
    }

    // Count the number of parts in a string
    // Used to help replace lack of split
    int count( String content, String delimeter )
    {
    int count = 0;
    int end;
    int start = 0;

    // Count occurances of delimeter
    do {
    end = content.indexOf( delimeter, start );
    start = end + 1;
    count = count + 1;
    } while( end > 0 );

    // Return occurance count
    return count;
    }

    // Reads response for specific header
    // Extracts and returns header value
    String getHeader( String content, String header )
    {
    int parts;
    int start;
    String line;
    String prefix;
    String result;

    // How many lines in response
    parts = count( content, "\n" );

    // Start on line after frame line
    // Look for header prefix match
    for( int p = 1; p < parts; p++ )
    {
    // Header line
    // Split into parts
    line = getValue( content, p, "\n" );
    prefix = getValue( line, 0, ":" );

    // If prefix matches
    if( prefix == header )
    {
    // Get value for header
    start = line.indexOf( ":" ) + 1;
    result = line.substring( start );
    break;
    }
    }

    // Return result
    return result;
    }

    // Get a specific section of a string
    // Based on delimeters
    // Used to replace lack of split
    String getValue( String content, int part, String delimeter )
    {
    int end;
    int start = 0;
    String result;

    // Iterate past unwanted values
    for( int count = 0; count < part; count++ )
    {
    end = content.indexOf( delimeter, start );
    start = end + delimeter.length();
    }

    // Get next occurance of delimeter
    // May return -1 if not found
    end = content.indexOf( delimeter, start );

    // If no more occurances
    if( end == -1 )
    {
    // Must be last value in content
    // Parse out remainder
    result = content.substring( start );
    } else {
    // Otherwise parse out segment of content
    result = content.substring( start, end );
    }

    // Clean off white space
    result.trim();

    // Return resulting content
    return result;
    }