Page History

case PUBLISH_REQUEST_CODE: {
//streamOptions.setRtmpUrl("rtmp://192.168.1.100:1935/live2");

       if (grantResults.length == 0 ||
 /**
          * Stream is created grantResults[0] != PackageManager.PERMISSION_GRANTED ||with method Session.createStream().
           grantResults[1] != PackageManager.PERMISSION_GRANTED) {
*/
        publishStream =   Logsession.i(TAG, "Permission has been denied by user"createStream(streamOptions);
    } else {
        mPublishButton.setEnabled(false);...
        /**
          * The options for the stream Method Stream.publish() is called to publish are setstream.
          */
 The stream name is passed when StreamOptions object is created.publishStream.publish();

        Log.i(TAG, "Permission */
has been granted by user");
    StreamOptions streamOptions = new StreamOptions(mPublishStreamView.getText().toString());
}
}

mPlayButton.setOnClickListener(new OnClickListener() {
    @Override
    public void onClick(View view) {
        mPlayButton.setEnabled(false);
        if (mPlayButton.getTag() == null || Integer.valueOf(R.string.action_play).equals(mPlayButton.getTag())) {
            /**
              * The options for the stream to play are set.
              * The stream name is passed when StreamOptions object is created.
              */
            StreamOptions streamOptions = new StreamOptions(mPlayStreamView.getText().toString());

            /**
              * Stream is created with method Session.createStream().
              */
            playStream = session.createStream(streamOptions);

            /**
              * Callback function for stream status change is added to make appropriate changes in controls of the interface when playing.
              */
            playStream.on(new StreamStatusEvent() {
                @Override
                public void onStreamStatus(final Stream stream, final StreamStatus streamStatus) {
                    runOnUiThread(new Runnable() {
                        @Override
                        public void run() {

                            if (StreamStatus.PLAYING.equals(streamStatus)) {
                                mPlayButton.setText(R.string.action_stop);
                                mPlayButton.setTag(R.string.action_stop);
                            } else if (StreamStatus.NOT_ENOUGH_BANDWIDTH.equals(streamStatus)) {
                                Log.w(TAG, "Not enough bandwidth stream " + stream.getName() + ", consider using lower video resolution or bitrate. " +
                                   "Bandwidth " + (Math.round(stream.getNetworkBandwidth() / 1000)) + " " +
                                   "bitrate " + (Math.round(stream.getRemoteBitrate() / 1000)));
                            } else {
                                mPlayButton.setText(R.string.action_play);
                                mPlayButton.setTag(R.string.action_play);
                            }
                            mPlayButton.setEnabled(true);
                            mPlayStatus.setText(streamStatus.toString());
                        }
                    });
                }
            });

            /**
              * Method Stream.play() is called to start playback of the stream.
              */
            playStream.play();

            SharedPreferences sharedPref = StreamingMinActivity.this.getPreferences(Context.MODE_PRIVATE);
            SharedPreferences.Editor editor = sharedPref.edit();
            editor.putString("play_stream", mPlayStreamView.getText().toString());
            editor.apply();
        } else {
            /**
              * Method Stream.stop() is called to stop playback of the stream.
              */
            playStream.stop();
            playStream = null;
        }
        View currentFocus = getCurrentFocus();
        if (currentFocus != null) {
            InputMethodManager inputManager = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
            inputManager.hideSoftInputFromWindow(currentFocus.getWindowToken(), InputMethodManager.HIDE_NOT_ALWAYS);
        }
    }
});

playStream.stop();
playStream = null;

publishStream.stop();
publishStream = null;

mConnectButton.setEnabled(false);

/**
  * Connection to WCS server is closed with method Session.disconnect().
  */
session.disconnect();

@Override
public void onDisconnection(final Connection connection) {
    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            mConnectButton.setText(R.string.action_connect);
            mConnectButton.setTag(R.string.action_connect);
            mConnectButton.setEnabled(true);
            mPublishButton.setText(R.string.action_publish);
            mPublishButton.setTag(R.string.action_publish);
            mPublishButton.setEnabled(false);
            mPlayButton.setText(R.string.action_play);
            mPlayButton.setTag(R.string.action_play);
            mPlayButton.setEnabled(false);
            mConnectStatus.setText(connection.getStatus());
            mPublishStatus.setText("");
            mPlayStatus.setText("");
        }
    });
}