Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for on_message (0.06 sec)

  1. docs/bucket/notifications/README.md

      # qos level is set to 1
      client.subscribe("minio", 1)
    
    def on_message(client, userdata, msg):
        print(msg.payload)
    
    # client_id is a randomly generated unique ID for the mqtt broker to identify the connection.
    client = mqtt.Client(client_id="myclientid",clean_session=False)
    
    client.on_connect = on_connect
    client.on_message = on_message
    
    client.connect("localhost",1883,60)
    client.loop_forever()
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/AutobahnTester.kt

              println("Executing test case $number/$count")
              startNanos.set(System.nanoTime())
            }
    
            override fun onMessage(
              webSocket: WebSocket,
              bytes: ByteString,
            ) {
              webSocket.send(bytes)
            }
    
            override fun onMessage(
              webSocket: WebSocket,
              text: String,
            ) {
              webSocket.send(text)
            }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. api/maven-api-core/src/main/java/org/apache/maven/api/plugin/MojoException.java

        protected Object source;
    
        protected String longMessage;
    
        /**
         * Constructs a new {@code MojoException} providing the source and a short and long message.
         * These messages are used to improve the message written at the end of Maven build.
         */
        public MojoException(Object source, String shortMessage, String longMessage) {
            super(shortMessage);
            this.source = source;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Mon May 13 09:53:45 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt

        } else {
          events.add(Open(webSocket, response))
        }
      }
    
      override fun onMessage(
        webSocket: WebSocket,
        bytes: ByteString,
      ) {
        Platform.get().log("[WS $name] onMessage", Platform.INFO, null)
        val delegate = delegate
        if (delegate != null) {
          this.delegate = null
          delegate.onMessage(webSocket, bytes)
        } else {
          events.add(Message(bytes = bytes))
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java

        webSocket.send(ByteString.decodeHex("deadbeef"));
        webSocket.close(1000, "Goodbye, World!");
      }
    
      @Override public void onMessage(WebSocket webSocket, String text) {
        System.out.println("MESSAGE: " + text);
      }
    
      @Override public void onMessage(WebSocket webSocket, ByteString bytes) {
        System.out.println("MESSAGE: " + bytes.hex());
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 04 11:40:21 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  6. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/MojoFailureException.java

         *
         * @param source
         * @param shortMessage
         * @param longMessage
         */
        public MojoFailureException(Object source, String shortMessage, String longMessage) {
            super(shortMessage);
            this.source = source;
            this.longMessage = longMessage;
        }
    
        /**
         * Construct a new <code>MojoFailureException</code> exception providing a message.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  7. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/MojoExecutionException.java

         *
         * @param source
         * @param shortMessage
         * @param longMessage
         */
        public MojoExecutionException(Object source, String shortMessage, String longMessage) {
            super(shortMessage);
            this.source = source;
            this.longMessage = longMessage;
        }
    
        /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt

        response: Response,
      ) {
      }
    
      /** Invoked when a text (type `0x1`) message has been received. */
      open fun onMessage(
        webSocket: WebSocket,
        text: String,
      ) {
      }
    
      /** Invoked when a binary (type `0x2`) message has been received. */
      open fun onMessage(
        webSocket: WebSocket,
        bytes: ByteString,
      ) {
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. samples/slack/src/main/java/okhttp3/slack/RtmSession.java

        System.out.println("onOpen: " + response);
      }
    
      // TOOD(jwilson): decode incoming messages and dispatch them somewhere.
      @Override public void onMessage(WebSocket webSocket, String text) {
        System.out.println("onMessage: " + text);
      }
    
      @Override public void onClosing(WebSocket webSocket, int code, String reason) {
        webSocket.close(1000, null);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Nov 19 20:16:58 UTC 2016
    - 2.4K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/exception/DefaultExceptionHandler.java

                String longMessage = null;
    
                if (t instanceof AbstractMojoExecutionException) {
                    longMessage = ((AbstractMojoExecutionException) t).getLongMessage();
                } else if (t instanceof MojoException) {
                    longMessage = ((MojoException) t).getLongMessage();
                }
    
                if (longMessage != null && !longMessage.isEmpty()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top