hosopy / actioncable-client-java Goto Github PK

build.gradle(project)
buildscript {
repositories {
google()
mavenCentral()
maven { url "https://jitpack.io" }
}
dependencies {
classpath "com.android.tools.build:gradle:7.0.4"
classpath "com.google.android.libraries.mapsplatform.secrets-gradle-plugin:secrets-gradle-plugin:2.0.0"
classpath 'org.jetbrains.kotlin:kotlin-gradle-plugin:1.6.10'

    // NOTE: Do not place your application dependencies here; they belong
    // in the individual module build.gradle files
}
}

task clean(type: Delete) {
delete rootProject.buildDir
}

.onFailed(new Subscription.FailedCallback() {
            @Override
            public void call(ActionCableException e) {
                Log.i("::CHECK", "onFailed");
                Log.i("::CHECK", e.getMessage());
                Toast.makeText(getApplicationContext(), "onFailed", Toast.LENGTH_SHORT).show(); //erro
            }
        }

String wsuri = "ws://52.37.206.155/cable?" + "email=" + Constants.EMAIL
                + "&sessionToken=" + Constants.SESSION_TOKEN
                + "&client=" + Constants.CLIENT;
        URI uri = null;
        try {
            uri = new URI(wsuri);
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }
        Consumer.Options options = new Consumer.Options();
        options.reconnection = true;
        options.reconnectionMaxAttempts = 1000;
        options.reconnectionDelayMax = 10;
        consumer = ActionCable.createConsumer(uri, options);
        // 2. Create subscription
        Channel appearanceChannel = new Channel("ConversationsChannel");
        appearanceChannel.addParam("room", "conversations:" + conversation.getId());
        subscription = consumer.getSubscriptions().create(appearanceChannel);
        subscription
                .onConnected(new Subscription.ConnectedCallback() {
                    @Override
                    public void call() {
                        isConnected = true;
                        Log.v("onConnected", "subscription has been successfully completed");
                    }
                }).onRejected(new Subscription.RejectedCallback() {
            @Override
            public void call() {
                isConnected = false;
                Log.v("onRejected", "subscription is rejected by the server");
            }
        }).onReceived(new Subscription.ReceivedCallback() {
            @Override
            public void call(final JsonElement data) {
                Log.v("onReceived", "subscription receives data from the server " + data.toString());
            }
        }).onDisconnected(new Subscription.DisconnectedCallback() {
            @Override
            public void call() {
                // Called when the subscription has been closed
                Log.v("onDisconnected", "subscription has been closed");
            }
        }).onFailed(new Subscription.FailedCallback() {
            @Override
            public void call(final ActionCableException e) {
                isConnected = false;
                // Called when the subscription encounters any error
                runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        Toast.makeText(ConversationActivity.this, "Disconnected", Toast.LENGTH_SHORT).show();
                    }
                });
                Log.e("onFailed", "subscription encounters any error");
                e.printStackTrace();
            }
        });

        consumer.connect();

  java.lang.OutOfMemoryError: pthread_create (1040KB stack) failed: Try again
      at java.lang.Thread.nativeCreate(Native Method)
      at java.lang.Thread.start(Thread.java:1063)
      at java.util.Timer$TimerImpl.<init>(Timer.java:192)
      at java.util.Timer.<init>(Timer.java:365)
      at java.util.Timer.<init>(Timer.java:384)
      at java.util.Timer.<init>(Timer.java:391)
      at com.hosopy.actioncable.ConnectionMonitor.poll(ConnectionMonitor.java:69)
      at com.hosopy.actioncable.ConnectionMonitor.access$200(ConnectionMonitor.java:6)
      at com.hosopy.actioncable.ConnectionMonitor$1.run(ConnectionMonitor.java:75)
      at java.util.Timer$TimerImpl.run(Timer.java:284)

    subscription
            .onConnected(new Subscription.ConnectedCallback() {
                @Override
                public void call() {
                    Log.e("Cable","Connected");
                    // Called when the subscription has been successfully completed
                }
            }).onRejected(new Subscription.RejectedCallback() {
        @Override
        public void call() {
            // Called when the subscription is rejected by the server
            Log.e("Cable","Rejected");
        }
    }).onReceived(new Subscription.ReceivedCallback() {
        @Override
        public void call(JsonElement data) {
            // Called when the subscription receives data from the server
            Log.e("Data",data.getAsString());
        }
    }).onDisconnected(new Subscription.DisconnectedCallback() {
        @Override
        public void call() {
            // Called when the subscription has been closed
        }
    }).onFailed(new Subscription.FailedCallback() {
        @Override
        public void call(ActionCableException e) {
            // Called when the subscription encounters any error
            Log.e("Cable","Error occurred");
        }
    });

    Consumer.Options options = new Consumer.Options();
    options.reconnection = true;

    options.reconnectionMaxAttempts = 30;
    options.reconnectionDelay = 3;
    options.reconnectionDelayMax = 30;
    options.okHttpClientFactory = new Connection.Options.OkHttpClientFactory() {
        @Override
        public OkHttpClient createOkHttpClient() {
            final OkHttpClient client = new OkHttpClient();
            client.setRetryOnConnectionFailure(true);
            client.setConnectTimeout(5, TimeUnit.MINUTES);
            client.networkInterceptors().add(new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    return null;
                }
            });
            return client;
        }
    };

    consumer = ActionCable.createConsumer(uri,options);

    subscriptions = consumer.getSubscriptions();

    // 2. Create subscription
    Channel roomChannel = new Channel("RoomChannel");
    subscription = subscriptions.create(roomChannel);

    subscription
            .onConnected(new Subscription.ConnectedCallback() {
                @Override
                public void call() {
                    // Called when the subscription has been successfully completed
                    Log.i("CHAT", "onConnected ");
                    subscription.perform("Hi");
                }
            }).onRejected(new Subscription.RejectedCallback() {
        @Override
        public void call() {
            // Called when the subscription is rejected by the server
            Log.i("CHAT", "onRejected ");
        }
    }).onReceived(new Subscription.ReceivedCallback() {
        @Override
        public void call(JsonElement data) {
            // Called when the subscription receives data from the server
            Log.i("CHAT", "onReceived " + data.toString());
        }
    }).onDisconnected(new Subscription.DisconnectedCallback() {
        @Override
        public void call() {
            // Called when the subscription has been closed
            Log.i("CHAT", "onDisconnected ");
        }
    }).onFailed(new Subscription.FailedCallback() {
        @Override
        public void call(ActionCableException e) {
            // Called when the subscription encounters any error
            Log.i("CHAT", "onFailed " + e.getMessage());
        }
    });

    // 3. Establish connection
    consumer.connect();