List of updateMessage() Examples

Examples of updateMessage()

org.apache.james.imapserver.store.ImapMailbox.updateMessage()
org.apache.marmotta.platform.core.api.task.Task.updateMessage()
org.eclipse.jface.wizard.IWizardContainer.updateMessage()
Updates the message (or error message) shown in the message line to reflect the state of the currently active page in this container.
This method is called by the container itself when its wizard page changes and may be called by the page at other times to force a message update.
org.jresearch.gossip.dao.ForumDAO.updateMessage()
DOCUMENT ME! @param messageForm @throws SQLException DOCUMENT ME!
org.mokai.persist.jdbc.MessageHandler.updateMessage()
Updates a {@link Message} record from the database. @param conn the Connection used to update the message. @param message the message to be updated. @return true if the message was found, false otherwise. @throws SQLException if something goes wrong.
org.mokai.persist.jdbc.sms.ConnectionsSmsHandler.updateMessage()

Examples of org.apache.james.imapserver.store.ImapMailbox.updateMessage()

            if ( ( useUids && idSet.includes( uid ) ) ||
                 ( !useUids && idSet.includes( msn ) ) )
            {
                SimpleImapMessage imapMessage = mailbox.getMessage( uid );
                storeFlags( imapMessage, directive, flags );
                mailbox.updateMessage( imapMessage );


                if ( ! directive.isSilent() ) {
                    StringBuffer out = new StringBuffer( "FLAGS " );
                    out.append( imapMessage.getFlags().format() );
                    response.fetchResponse( msn, out.toString() );

View Full Code Here

Examples of org.apache.james.imapserver.store.ImapMailbox.updateMessage()

            if ( ( useUids && idSet.includes( uid ) ) ||
                 ( !useUids && idSet.includes( msn ) ) )
            {
                SimpleImapMessage imapMessage = mailbox.getMessage( uid );
                storeFlags( imapMessage, directive, flags );
                mailbox.updateMessage( imapMessage );


                if ( ! directive.isSilent() ) {
                    StringBuffer out = new StringBuffer( "FLAGS " );
                    out.append( imapMessage.getFlags().format() );
                    response.fetchResponse( msn, out.toString() );

View Full Code Here

Examples of org.apache.james.imapserver.store.ImapMailbox.updateMessage()

            if ( ( useUids && idSet.includes( uid ) ) ||
                 ( !useUids && idSet.includes( msn ) ) )
            {
                SimpleImapMessage imapMessage = mailbox.getMessage( uid );
                storeFlags( imapMessage, directive, flags );
                mailbox.updateMessage( imapMessage );


                if ( ! directive.isSilent() ) {
                    StringBuffer out = new StringBuffer( "FLAGS " );
                    out.append( imapMessage.getFlags().format() );
                    response.fetchResponse( msn, out.toString() );

View Full Code Here

Examples of org.apache.marmotta.platform.core.api.task.Task.updateMessage()

        if (type == null || !importService.getAcceptTypes().contains(type)) return Response.status(412).entity("define a valid content-type (types: "+importService.getAcceptTypes()+")").build();
        final String finalType = type;
        final InputStream in = request.getInputStream();


        Task t = taskManagerService.createTask(String.format("Upload-Import from %s (%s)", request.getRemoteHost(), finalType), TASK_GROUP_NAME);
        t.updateMessage("preparing import...");
        t.updateDetailMessage("type", finalType);
        try {
            //create context
            URI context = getContext(context_string);
            if (context != null) {

View Full Code Here

Examples of org.apache.marmotta.platform.core.api.task.Task.updateMessage()

            URI context = getContext(context_string);
            if (context != null) {
                t.updateDetailMessage("context", context.toString());
            }


            t.updateMessage("importing data...");
            importService.importData(in,finalType, userService.getCurrentUser(), context);
            t.updateMessage("import complete");


            return Response.ok().entity("import of content successful\n").build();
        } catch(Exception ex) {

View Full Code Here

Examples of org.apache.marmotta.platform.core.api.task.Task.updateMessage()

                t.updateDetailMessage("context", context.toString());
            }


            t.updateMessage("importing data...");
            importService.importData(in,finalType, userService.getCurrentUser(), context);
            t.updateMessage("import complete");


            return Response.ok().entity("import of content successful\n").build();
        } catch(Exception ex) {
            log.error("error while importing", ex);
            return Response.status(500).entity("error while importing: " + ex.getMessage()).build();

View Full Code Here

Examples of org.apache.marmotta.platform.core.api.task.Task.updateMessage()

        private Task preProcess(HttpRequest request) {
            final RequestLine rl = request.getRequestLine();
            final String taskName = String.format("%S %s %S", rl.getMethod(), rl.getUri(), request.getProtocolVersion());


            final Task task = taskManagerService.createSubTask(taskName, TASK_GROUP_CLIENT);
            task.updateMessage("preparing request");
            task.updateDetailMessage("method", rl.getMethod());
            task.updateDetailMessage("url", rl.getUri());
            // TODO: some more detail messages?


            if (request instanceof HttpEntityEnclosingRequest) {

View Full Code Here

Examples of org.apache.marmotta.platform.core.api.task.Task.updateMessage()

                // To report upload progress, the entity is wrapped in a MonitoredHttpEntity.
                final HttpEntityEnclosingRequest entityRequest = (HttpEntityEnclosingRequest) request;
                entityRequest.setEntity(new MonitoredHttpEntity(entityRequest.getEntity(), task, bytesSent));
            }


            task.updateMessage("sending request");
            return task;
        }


        private HttpResponse postProcess(final HttpResponse response, HttpContext context, final Task task) {
            requestsExecuted.incrementAndGet();

View Full Code Here

Examples of org.apache.marmotta.platform.core.api.task.Task.updateMessage()

    Runnable r = new Runnable() {


      @Override
      public void run() {
        final Task task = taskManagerService.createTask("Directory import watch", TASK_GROUP);
        task.updateMessage("watching...");
        task.updateDetailMessage(TASK_DETAIL_PATH, path);


        try {
          Path root = Paths.get(path);
          WatchService watcher = root.getFileSystem().newWatchService();

View Full Code Here

Examples of org.apache.marmotta.platform.core.api.task.Task.updateMessage()

                  register(Paths.get(dir.toString(), item.toString()), watcher, StandardWatchEventKinds.ENTRY_CREATE, StandardWatchEventKinds.ENTRY_DELETE);
                  task.updateProgress(++count);
                } else {
                  URI context = getTargetContext(file);
                  log.debug("Importing '{}'...", file.getAbsolutePath());
                  task.updateMessage("importing...");
                  task.updateDetailMessage(TASK_DETAIL_PATH, file.getAbsolutePath());
                  task.updateDetailMessage(TASK_DETAIL_CONTEXT, context.stringValue());
                  if (execImport(file, context)) {
                    log.info("Sucessfully imported file '{}' into {}", file.getAbsolutePath(), context.stringValue());
                    try {

View Full Code Here

0 1 2 3

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.