Examples of IMessageHandler

net.sourceforge.squirrel_sql.fw.util.IMessageHandler
org.apache.qpid.management.domain.handler.base.IMessageHandler
Interface definition for a processor able to deal with a specific message. The concrete implementor must define what has to be done with the supplied (incoming) stream and the sequence number. @author Andrea Gazzarini.
org.aspectj.bridge.IMessageHandler
Handle messages, logging and/or aborting as appropriate. Implementations define which messages are logged and whether the handler aborts the process. For messages that are costly to construct, clients may query {@link #isIgnoring(IMessage.Kind)}to avoid construction if the message will be ignored. Clients passing messages to an IMessageHandler should not interfere with aborts by catching AbortException unless otherwise required by their logic or the message handler.
org.xlightweb.AbstractHttpConnection.IMessageHandler

Examples of org.aspectj.bridge.IMessageHandler

    }
    IMessageHolder holder = messageHolder;
    int numPreviousErrors;
    if (null == holder) {
      MessageHandler mhandler = new MessageHandler(true);
      final IMessageHandler delegate;
      delegate = new AntMessageHandler(this.logger, this.verbose, false);
      mhandler.setInterceptor(delegate);
      holder = mhandler;
      numPreviousErrors = 0;
    } else {

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

      AjcConfigParser parser = new AjcConfigParser(buildConfig, handler);
      parser.parseCommandLine(args);
      boolean swi = buildConfig.getShowWeavingInformation();
      // Now jump through firey hoops to turn them on/off
      if (handler instanceof CountingMessageHandler) {
        IMessageHandler delegate = ((CountingMessageHandler) handler).delegate;
        if (swi) {
          delegate.dontIgnore(IMessage.WEAVEINFO);
        } else {
          delegate.ignore(IMessage.WEAVEINFO);
        }
      }


      boolean incrementalMode = buildConfig.isIncrementalMode() || buildConfig.isIncrementalFileMode();

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

  private void ensureAspectJAttributesUnpacked() {
    if ((bitflag & UNPACKED_AJATTRIBUTES) != 0) {
      return;
    }
    bitflag |= UNPACKED_AJATTRIBUTES;
    IMessageHandler msgHandler = getResolvedTypeX().getWorld().getMessageHandler();
    // Pass in empty list that can store things for readAj5 to process
    List<AjAttribute> l = null;
    try {
      l = Utility.readAjAttributes(className, javaClass.getAttributes(), getResolvedTypeX().getSourceContext(),
          getResolvedTypeX().getWorld(), AjAttribute.WeaverVersionInfo.UNKNOWN,
          new BcelConstantPoolReader(javaClass.getConstantPool()));
    } catch (RuntimeException re) {
      throw new RuntimeException("Problem processing attributes in " + javaClass.getFileName(), re);
    }
    List<ResolvedPointcutDefinition> pointcuts = new ArrayList<ResolvedPointcutDefinition>();
    typeMungers = new ArrayList<ConcreteTypeMunger>();
    declares = new ArrayList<Declare>();
    processAttributes(l, pointcuts, false);
    ReferenceType type = getResolvedTypeX();
    AsmManager asmManager = ((BcelWorld) type.getWorld()).getModelAsAsmManager();
    l = AtAjAttributes.readAj5ClassAttributes(asmManager, javaClass, type, type.getSourceContext(), msgHandler,
        isCodeStyleAspect);
    AjAttribute.Aspect deferredAspectAttribute = processAttributes(l, pointcuts, true);


    if (pointcuts.size() == 0) {
      this.pointcuts = ResolvedPointcutDefinition.NO_POINTCUTS;
    } else {
      this.pointcuts = pointcuts.toArray(new ResolvedPointcutDefinition[pointcuts.size()]);
    }


    resolveAnnotationDeclares(l);


    if (deferredAspectAttribute != null) {
      // we can finally process the aspect and its associated perclause...
      perClause = deferredAspectAttribute.reifyFromAtAspectJ(this.getResolvedTypeX());
    }
    if (isAspect() && !Modifier.isAbstract(getModifiers()) && isGeneric()) {
      msgHandler.handleMessage(MessageUtil.error("The generic aspect '" + getResolvedTypeX().getName()
          + "' must be declared abstract", getResolvedTypeX().getSourceLocation()));
    }


  }

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

    return supportedPrimitives;
  }


  /* for testing */
  IMessageHandler setCustomMessageHandler(IMessageHandler aHandler) {
    IMessageHandler current = getWorld().getMessageHandler();
    getWorld().setMessageHandler(aHandler);
    return current;
  }

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

    return supportedPrimitives;
  }


  /* for testing */
  IMessageHandler setCustomMessageHandler(IMessageHandler aHandler) {
    IMessageHandler current = getWorld().getMessageHandler();
    getWorld().setMessageHandler(aHandler);
    return current;
  }

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

  private void ensureAspectJAttributesUnpacked() {
    if ((bitflag & UNPACKED_AJATTRIBUTES) != 0) {
      return;
    }
    bitflag |= UNPACKED_AJATTRIBUTES;
    IMessageHandler msgHandler = getResolvedTypeX().getWorld().getMessageHandler();
    // Pass in empty list that can store things for readAj5 to process
    List<AjAttribute> l = null;
    try {
      l = Utility.readAjAttributes(className, javaClass.getAttributes(), getResolvedTypeX().getSourceContext(),
          getResolvedTypeX().getWorld(), AjAttribute.WeaverVersionInfo.UNKNOWN, new BcelConstantPoolReader(javaClass
              .getConstantPool()));
    } catch (RuntimeException re) {
      throw new RuntimeException("Problem processing attributes in " + javaClass.getFileName(), re);
    }
    List<ResolvedPointcutDefinition> pointcuts = new ArrayList<ResolvedPointcutDefinition>();
    typeMungers = new ArrayList<ConcreteTypeMunger>();
    declares = new ArrayList<Declare>();
    processAttributes(l, pointcuts, false);
    l = AtAjAttributes.readAj5ClassAttributes(((BcelWorld) getResolvedTypeX().getWorld()).getModelAsAsmManager(), javaClass,
        getResolvedTypeX(), getResolvedTypeX().getSourceContext(), msgHandler, isCodeStyleAspect);
    AjAttribute.Aspect deferredAspectAttribute = processAttributes(l, pointcuts, true);


    if (pointcuts.size() == 0) {
      this.pointcuts = ResolvedPointcutDefinition.NO_POINTCUTS;
    } else {
      this.pointcuts = pointcuts.toArray(new ResolvedPointcutDefinition[pointcuts.size()]);
    }


    resolveAnnotationDeclares(l);


    if (deferredAspectAttribute != null) {
      // we can finally process the aspect and its associated perclause...
      perClause = deferredAspectAttribute.reifyFromAtAspectJ(this.getResolvedTypeX());
    }
    if (isAspect() && !Modifier.isAbstract(getModifiers()) && isGeneric()) {
      msgHandler.handleMessage(MessageUtil.error("The generic aspect '" + getResolvedTypeX().getName()
          + "' must be declared abstract", getResolvedTypeX().getSourceLocation()));
    }


  }

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

    this.inJava5Mode = false;
    this.noAtAspectJAnnotationProcessing = noAtAspectJProcessing;
    
    if (compiler.options.complianceLevel == CompilerOptions.JDK1_5) inJava5Mode = true;
    
    IMessageHandler msgHandler = world.getMessageHandler();
    weaverMessageHandler = new WeaverMessageHandler(msgHandler, compiler);
    world.setMessageHandler(weaverMessageHandler);
  }

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

      return supportedPrimitives;
    }
    
    /* for testing */
    IMessageHandler setCustomMessageHandler(IMessageHandler aHandler) {
      IMessageHandler current = getWorld().getMessageHandler();
      getWorld().setMessageHandler(aHandler);
      return current;
    }

View Full Code Here

Examples of org.aspectj.bridge.IMessageHandler

        {
        MessageHandler handler = new MessageHandler();
        if (!verbose) {
          handler.ignore(IMessage.INFO);
        }
        final IMessageHandler delegate 
          = verbose ? MessagePrinter.VERBOSE: MessagePrinter.TERSE;
      handler.setInterceptor(delegate);
      holder = handler;
        }
        try {

View Full Code Here

Examples of org.xlightweb.AbstractHttpConnection.IMessageHandler

  
    final ByteBuffer[] parserBody(AbstractHttpConnection httpConnection, ByteBuffer[] rawData) throws IOException {


        dataSource.parse(rawData);
        if (dataSource.isComplete()) {
            IMessageHandler mh = messageHandler;
            reset();
            
            if (mh != null) {
                mh.onMessageReceived();
            } 
        }
        
        rawData = HttpUtils.compact(rawData);

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.