- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for on_message (0.06 sec)
-
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) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
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) -
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)