List of addToQueue() Examples

Examples of addToQueue()

com.facebook.presto.hive.HiveSplitSourceProvider.HiveSplitSource.addToQueue()
net.suberic.util.thread.ActionThread.addToQueue()
This adds an item to the queue. It also starts up the Thread if it's not already running.
org.kapott.hbci.GV.HBCIJob.addToQueue()

Hinzuf�gen dieses Jobs zu einem HBCI-Dialog. Diese Methode arbeitet analog zu {@link #addToQueue(String)}, nur dass hier die customerid mit der Kunden-ID vorbelegt ist, wie sie im aktuellen Passport gespeichert ist.
org.kapott.hbci.GV.HBCIJobImpl.addToQueue()

Examples of com.facebook.presto.hive.HiveSplitSourceProvider.HiveSplitSource.addToQueue()

        assertEquals(hiveSplitSource.getOutstandingSplitCount(), 9);
        assertFalse(suspendingExecutor.isSuspended());


        // add two more splits so the source is now full and verify that the executor is suspended
        hiveSplitSource.addToQueue(new TestSplit(11));
        hiveSplitSource.addToQueue(new TestSplit(12));
        assertEquals(hiveSplitSource.getOutstandingSplitCount(), 11);
        assertTrue(suspendingExecutor.isSuspended());


        // remove two splits so the source is no longer full and verify the executor is resumed
        assertEquals(hiveSplitSource.getNextBatch(2).size(), 2);

View Full Code Here

Examples of com.facebook.presto.hive.HiveSplitSourceProvider.HiveSplitSource.addToQueue()

        SuspendingExecutor suspendingExecutor = createSuspendingExecutor();
        HiveSplitSource hiveSplitSource = new HiveSplitSource("test", 10, suspendingExecutor);


        // add some splits
        for (int i = 0; i < 5; i++) {
            hiveSplitSource.addToQueue(new TestSplit(i));
            assertEquals(hiveSplitSource.getOutstandingSplitCount(), i + 1);
        }


        // remove a split and verify
        assertEquals(hiveSplitSource.getNextBatch(1).size(), 1);

View Full Code Here

Examples of com.facebook.presto.hive.HiveSplitSourceProvider.HiveSplitSource.addToQueue()

            assertEquals(e.getCause().getMessage(), "test");
        }
        assertEquals(hiveSplitSource.getOutstandingSplitCount(), 4);


        // attempt to add another split and verify it does not work
        hiveSplitSource.addToQueue(new TestSplit(99));
        assertEquals(hiveSplitSource.getOutstandingSplitCount(), 4);


        // fail source again
        hiveSplitSource.fail(new RuntimeException("another failure"));
        assertEquals(hiveSplitSource.getOutstandingSplitCount(), 4);

View Full Code Here

Examples of com.facebook.presto.hive.HiveSplitSourceProvider.HiveSplitSource.addToQueue()

            // sleep for a bit, and assure the thread is blocked
            TimeUnit.MILLISECONDS.sleep(200);
            assertTrue(!splits.isDone());


            // add a split
            hiveSplitSource.addToQueue(new TestSplit(33));


            // wait for thread to get the split
            ConnectorSplit split = splits.get(200, TimeUnit.MILLISECONDS);
            assertSame(split.getInfo(), 33);
        }

View Full Code Here

Examples of net.suberic.util.thread.ActionThread.addToQueue()

    final Address[] final_addresses = addresses;
    final boolean final_delete = deleteOnSuccess;
    final boolean final_expunge = expunge;


    ActionThread folderThread = getMessageInfo().getFolderInfo().getFolderThread();
    folderThread.addToQueue(new javax.swing.AbstractAction() {
        public void actionPerformed(java.awt.event.ActionEvent ae) {
          try {
            getMessageInfo().bounceMessage(final_addresses);
            if (final_delete)
              deleteMessage(final_expunge);

View Full Code Here

Examples of net.suberic.util.thread.ActionThread.addToQueue()

          }
        }
      };


      if (Thread.currentThread() != folderThread) {
        folderThread.addToQueue(deleteInProgressAction, new java.awt.event.ActionEvent(this, 0, "message-bounce"));
      } else {
        deleteInProgressAction.actionPerformed(null);
      }
  }

View Full Code Here

Examples of net.suberic.util.thread.ActionThread.addToQueue()

        if (fdp != null)
          fdp.moveSelectionOnRemoval(v);
      }




      folderThread.addToQueue(new javax.swing.AbstractAction() {
          public void actionPerformed(java.awt.event.ActionEvent ae) {
            try {
              deleteMessage();
            } finally {

View Full Code Here

Examples of net.suberic.util.thread.ActionThread.addToQueue()

              }
            }
          }
        };


      thread.addToQueue(connectionAction, new java.awt.event.ActionEvent(this, 0, "connectStore"));
    }


  }


  /**

View Full Code Here

Examples of org.kapott.hbci.GV.HBCIJob.addToQueue()

          if (getSupportedLowlevelJobs().getProperty("SEPAInfo")!=null) {
            HBCIUtils.log("trying to fetch SEPA information from institute", HBCIUtils.LOG_INFO);
            
            // HKSPA wird unterstuetzt
            HBCIJob sepainfo=newJob("SEPAInfo");
            sepainfo.addToQueue();
            HBCIExecStatus status=execute();
            if (status.isOK()) {
              HBCIUtils.log("successfully fetched information about SEPA accounts from institute", HBCIUtils.LOG_INFO);
              
              passport.getUPD().setProperty("_fetchedSEPA","1");

View Full Code Here

Examples of org.kapott.hbci.GV.HBCIJob.addToQueue()

                            } else {
                                // leerzeile gefunden - damit ist die parameter-
                                // spez. f�r den aktuellen job beendet
                                
                                // aktuellen job zur job-queue hinzuf�gen
                                job.addToQueue(customerId);
                                state=STATE_NEED_JOBNAME;
                            }
                        }
                    }

View Full Code Here

0 1 2 3 4

TOP

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.