Package org.cometd.bayeux.server

Examples of org.cometd.bayeux.server.BayeuxServer.addExtension()

41
42
43
44
45
46
47
48
49
50
51
        _processor = new ServerAnnotationProcessor(bayeux, oort, seti);
        _service = new OortChatService();
        _processor.process(_service);

        bayeux.addExtension(new TimesyncExtension());
    }

    public void destroy()
    {
        _processor.deprocess(_service);
View Full Code Here
504
505
506
507
508
509
510
511
512
513
514
                ++ackExtensions;
        Assert.assertEquals(1, ackExtensions);

        Server serverB = startServer(0);
        BayeuxServer bayeuxServerB = (BayeuxServer)serverB.getAttribute(BayeuxServer.ATTRIBUTE);
        bayeuxServerB.addExtension(new AcknowledgedMessagesExtension());
        Oort oortB = startOort(serverB);
        stopOort(oortB);
        oortB.setAckExtensionEnabled(true);
        oortB.start();
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        bayeux.setSecurityPolicy(new DefaultSecurityPolicy());

        // Demo lazy messages
        if (Boolean.getBoolean("LAZY"))
        {
            bayeux.addExtension(new BayeuxServer.Extension.Adapter()
            {
                @Override
                public boolean rcv(ServerSession from, Mutable message)
                {
                    if (message.getChannel().startsWith("/chat/") && !message.isPublishReply() && message.getData().toString().contains("lazy"))
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
    ServletContext servletContext = this.getServletContext();

    // get the bayeux server and register the bayeux ack extension.
    BayeuxServer bayeux = (BayeuxServer) servletContext
        .getAttribute(BayeuxServer.ATTRIBUTE);
    bayeux.addExtension(new AcknowledgedMessagesExtension());

    // parse the coweb configuration file for this application.
    ServletConfig config = this.getServletConfig();
    Map<String, Object> cowebConfig = null;
    try {
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
    String captureOutgoing = (String) cowebConfig.get("captureOutgoing");
    if (captureIncoming != null || captureOutgoing != null) {
      try {
        CowebExtension cowebExtension = new CowebExtension(
            captureIncoming, captureOutgoing);
        bayeux.addExtension(cowebExtension);
      } catch (Exception e) {
        log.info(e.getMessage());
      }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.