datachannel.java

DataChannel.Init dcInit = new DataChannel.Init();
dataChannel = peerConnection.createDataChannel("1", dcInit);
dataChannel.registerObserver(new CustomDataChannelObserver(){

            @Override
            public void onMessage(DataChannel.Buffer buffer) {
                super.onMessage(buffer);
                // will be called when message is received from another peer
            }
});