@@ -19,13 +19,13 @@ public WebsocketEndpoints(WebsocketConnection client) {
1919
2020 @ Override
2121 public void onOpen (Session session , EndpointConfig config ) {
22- client .sessionReady .complete (session );
22+ client .sessionReady () .complete (session );
2323 log .info ("Connected to server" );
2424
2525 // onOpen-Handler
26- if (client .onOpenHandler != null ) {
26+ if (client .onOpenHandler () != null ) {
2727 try {
28- client .onOpenHandler .accept (session );
28+ client .onOpenHandler () .accept (session );
2929 } catch (Exception e ) {
3030 log .error ("Error executing onOpen handler: " , e );
3131 }
@@ -35,9 +35,9 @@ public void onOpen(Session session, EndpointConfig config) {
3535 session .addMessageHandler (String .class , message -> {
3636 log .debug ("Received message: " + message );
3737 client .awaitOpen (Duration .ofMillis (5000L ));
38- if (client .onMessageHandler != null ) {
38+ if (client .onMessageHandler () != null ) {
3939 try {
40- client .onMessageHandler .accept (message );
40+ client .onMessageHandler () .accept (message );
4141 } catch (Exception e ) {
4242 log .error ("Error executing onMessage handler: " , e );
4343 }
@@ -49,9 +49,9 @@ public void onOpen(Session session, EndpointConfig config) {
4949 public void onClose (Session session , CloseReason closeReason ) {
5050 Session s = client .awaitOpen (Duration .ofMillis (5000L ));
5151 log .info ("Disconnected from server: {}" , closeReason );
52- if (client .onCloseHandler != null ) {
52+ if (client .onCloseHandler () != null ) {
5353 try {
54- client .onCloseHandler .accept (s );
54+ client .onCloseHandler () .accept (s );
5555 } catch (Exception e ) {
5656 log .error ("Error executing onClose handler: " , e );
5757 }
@@ -68,9 +68,9 @@ public void onClose(Session session, CloseReason closeReason) {
6868 public void onError (Session session , Throwable throwable ) {
6969 client .awaitOpen (Duration .ofMillis (5000L ));
7070 log .error ("Error occurred: " , throwable );
71- if (client .onErrorHandler != null ) {
71+ if (client .onErrorHandler () != null ) {
7272 try {
73- client .onErrorHandler .accept (throwable );
73+ client .onErrorHandler () .accept (throwable );
7474 } catch (Exception e ) {
7575 log .error ("Error executing onError handler: " , e );
7676 }
0 commit comments