Examples of connect()


Examples of org.gridkit.coherence.txlite.TxSession.connect()

   
    TxManager txman = TxLite.getManager();
   
    TxSession rsession = txman.openReadOnlySession();
    TxSession wsession = txman.openReadWriteSession();
    NamedCache writeA = wsession.connect(cacheA);
    NamedCache rrA = rsession.connect(cacheA);
    NamedCache rcA = txman.toReadCommited(cacheA);

    Assert.assertThat(rrA.get("A"), IsNull.nullValue());
    Assert.assertThat(rcA.get("A"), IsNull.nullValue());
View Full Code Here

Examples of org.gstreamer.Bus.connect()

        }
        player = new PlayBin2("Example Player");
        player.setInputFile(new File(args[0]));
        Bus bus = player.getBus();
        tags = new TagList();
        bus.connect(new Bus.TAG() {
            public void tagsFound(GstObject source, TagList tagList) {
                System.out.println("Got TAG event");
                for (String tag : tagList.getTagNames()) {
                    System.out.println("Tag " + tag + " = " + tagList.getValue(tag, 0));
                }
View Full Code Here

Examples of org.gstreamer.Element.connect()

        /* put together a pipeline */
        pipeline.addMany(source, demux);
        Element.linkPads(source, "src", demux, "sink");
       
        /* listen for newly created pads */
        demux.connect(new Element.PAD_ADDED() {
            public void padAdded(Element element, Pad pad) {
               System.out.println("New Pad " + pad.getName() + " was created");
            }
        });
       
View Full Code Here

Examples of org.gstreamer.elements.AppSrc.connect()

                frame.add(panel, BorderLayout.CENTER);
                Element videosink = panel.getElement();
                pipeline.addMany(appsrc, srcfilter, videorate, ratefilter, videosink);
                Element.linkMany(appsrc, srcfilter, videorate, ratefilter, videosink);
                appsrc.set("emit-signals", true);
                appsrc.connect(new AppSrc.NEED_DATA() {
                    byte color = 0;
                    byte[] data = new byte[width * height * 2];
                    public void needData(AppSrc elem, int size) {
                        System.out.println("NEED_DATA: Element=" + elem.getNativeAddress()
                                + " size=" + size);
View Full Code Here

Examples of org.gstreamer.elements.DecodeBin2.connect()

        audioBin.addMany(conv, resample, sink);
        Element.linkMany(conv, resample, sink);
        audioBin.addPad(new GhostPad("sink", conv.getStaticPad("sink")));
        pipe.add(audioBin);
       
        decodeBin.connect(new DecodeBin2.NEW_DECODED_PAD() {
            public void newDecodedPad(DecodeBin2 elem, Pad pad, boolean last) {
               
                /* only link once */
                if (pad.isLinked()) {
                    return;
View Full Code Here

Examples of org.gstreamer.elements.FakeSink.connect()

                pipe.stop();
                done.countDown();
            }
        };
        audio.connect(handoff);
        video.connect(handoff);
       
        // Start the pipeline playing
        pipe.pause();
        try {
            done.await();
View Full Code Here

Examples of org.gstreamer.elements.FakeSrc.connect()

                fakesrc.set("sizemax", width * height * 2);
                fakesrc.set("sizetype", 2);
                fakesrc.set("sync", true);
                fakesrc.set("is-live", true);
                fakesrc.set("filltype", 1); // Don't fill the buffer before handoff
                fakesrc.connect(new BaseSrc.HANDOFF() {
                    byte color = 0;
                    byte[] data = new byte[width * height * 2];
                    public void handoff(BaseSrc src, Buffer buffer, Pad pad) {
                        System.out.println("HANDOFF: Element=" + src.getNativeAddress()
                                + " buffer=" + buffer.getNativeAddress()
View Full Code Here

Examples of org.gstreamer.elements.TypeFind.connect()

        /* put together a pipeline */
        pipeline.addMany(source, typefind);
        Element.linkMany(source, typefind);
       
        /* listen for types found */
        typefind.connect(new TypeFind.HAVE_TYPE() {

            public void typeFound(Element elem, int probability, Caps caps) {
                System.out.printf("New type found: probability=%d caps=%s\n",
                        probability, caps.toString());
            }
View Full Code Here

Examples of org.gudy.azureus2.plugins.messaging.generic.GenericMessageConnection.connect()

                  sem.release();
                }
              });
           
     
            con.connect();
           
            sem.reserve();
           
            Thread.sleep( 1000 );
          }
View Full Code Here

Examples of org.gvsig.remoteClient.wms.WMSClient.connect()

            @Override
            protected Object doInBackground() throws Exception {
              try {
                final String url2 = ci.getUrl();
                WMSClient client = new WMSClient(url2);
                client.connect(new ICancellable() {

                  @Override
                  public boolean isCanceled() {
                    return false;
                  }
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.