小编Vij*_*var的帖子

有两个程序:订阅者和发布者...订阅者能够将消息放入主题并且消息成功发送.当我在浏览器上检查activemq服务器时,它显示1 msg排队.但是当我运行消费者代码时,它没有收到消息

这是生产者代码:

import javax.jms.*;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class producer {

    private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;

    public static void main(String[] args) throws JMSException {

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        Connection connection = connectionFactory.createConnection();
        connection.start();

        // JMS messages are sent and received using a Session. We will
        // create here a non-transactional session object. If you want
        // to use transactions you should set the first parameter to 'true'
        Session session = connection.createSession(false,
                Session.AUTO_ACKNOWLEDGE);

        Topic topic = session.createTopic("testt"); …

我能够构建libjingle库,并在Android上构建AppRTCDemo应用程序.我能够连接到同伴并成功共享音频和视频.现在我想扩展它以发送数据(比如Text"HelloWorld").我想将DataChannel集成到它中,以便我也可以通过它发送数据.

我有几个问题:

1. 是否可以将DataChannel与原生webrtc一起使用？我的意思是我要做的是支持吗？
2. 是否有任何示例应用程序或示例可以为我解决此问题？

期待你的支持!