Java 类org.aspectj.lang.Aspects 实例源码

@Before
public void setUp() throws Exception {
    this.personRepository = new MockPersonRepository(new MockPerson());
    this.objectFactory = new ObjectFactory<Person>() {
        public Person getObject() {
            return new MockPerson();
        }
    };


    this.personService = new DefaultPersonService(personRepository, new MockReferenceRepository(), new MockDisclosureRecalculationStrategyRepository(), new NoOpIdentifierGenerator(), new MockReconciler(ReconciliationType.NONE));
    this.personService.setIdCardGenerator(new MockIdCardGenerator());
    this.personService.setPersonObjectFactory(this.objectFactory);
    reconciliationCriteria = new MockReconciliationCriteria();
    setReconciliationCriteria(reconciliationCriteria);
    final SoRSpecificationThreadLocalAspect aspect = Aspects.aspectOf(SoRSpecificationThreadLocalAspect.class);
    aspect.setSystemOfRecordRepository(new MockSystemOfRecordRepository());    }

private void dumpMongoTrackingStats(String batchId) throws UnknownHostException {
    Map<String, ? extends Map<String, Pair<AtomicLong, AtomicLong>>> stats = Aspects.aspectOf(MongoTrackingAspect.class).getStats();

    if (stats != null) {
        String hostName = InetAddress.getLocalHost().getHostName();
        hostName = hostName.replaceAll("\\.", "#");
        Update update = new Update();
        update.set("executionStats." + hostName, stats);

        LOG.info("Dumping runtime stats to db for job {}", batchId);
        LOG.info(stats.toString());

        // TODO: move to BatchJobDAO
        mongo.updateFirst(new Query(Criteria.where(BATCH_JOB_ID).is(batchId)), update, "newBatchJob");
        Aspects.aspectOf(MongoTrackingAspect.class).reset();
    }
}

private void dumpStageTrackingStats(String jobId) {
    Map<String, Pair<AtomicLong, AtomicLong>> stats = Aspects.aspectOf(StageTrackingAspect.class).getStats();

    if (stats != null) {

        for (Entry<String, Pair<AtomicLong, AtomicLong>> statsEntry : stats.entrySet()) {
            Stage stage = new Stage(statsEntry.getKey(), BATCH_JOB_STAGE_DESC);
            stage.setElapsedTime(statsEntry.getValue().getRight().longValue());
            stage.setProcessingInformation("Invocation count: " + statsEntry.getValue().getLeft().longValue());

            batchJobDAO.saveBatchJobStage(jobId, stage);
        }

        Aspects.aspectOf(StageTrackingAspect.class).reset();
    }
}

@Bean
public DrawGuessAspect drawGuessAspect(DrawGuess service, DrawGuessWebSocket webSocket) {
    DrawGuessAspect aspect = Aspects.aspectOf(DrawGuessAspect.class);
    aspect.setService(service);
    aspect.setWebSocket(webSocket);
    return aspect;
}

@After("set(@eu.crisis_economics.abm.annotation.Report * *) && args(newValue) && @annotation(newsAnnotation) && target(sender)")
public void collectField(Object newValue, eu.crisis_economics.abm.annotation.Report newsAnnotation, Object sender){
    if (newsAnnotation.interval() == 0 && !(newValue instanceof Collection)){
        DataCollection aspectOf = Aspects.aspectOf(DataCollection.class);
        Set<Object> set = aspectOf.collectors.get(newsAnnotation.value());
        if (set != null){
            for (Object collector : set) {
                aspectOf.handleData(newsAnnotation.value(), newValue, collector, sender, Collect.ChangeType.CHANGE);
            }
        }
    }
}

@AfterReturning(pointcut="execution(@eu.crisis_economics.abm.annotation.Report * *(..)) && @annotation(newsAnnotation) && target(sender)", returning="returnValue")
public void collectReturnValue(Object returnValue, eu.crisis_economics.abm.annotation.Report newsAnnotation, Object sender){
    if (newsAnnotation.interval() == 0){
        DataCollection aspectOf = Aspects.aspectOf(DataCollection.class);
        Set<Object> set = aspectOf.collectors.get(newsAnnotation.value());
        if (set != null){
            for (Object collector : set) {
                aspectOf.handleData(newsAnnotation.value(), returnValue, collector, sender, Collect.ChangeType.CHANGE);
            }
        }
    }
}

@AfterReturning(pointcut="(addObject() || removeObject()) && dataReporterCode() && this(reporter) && args(.., arg)",
        returning="result")
public void catchCollectionModification(JoinPoint jp, JoinPoint.EnclosingStaticPart enc, Object arg, Object reporter, Object result){
    DataCollection aspectOf = Aspects.aspectOf(DataCollection.class);
    Object targetCollection = jp.getTarget();
    Class<?> dataReporterClass = enc.getSignature().getDeclaringType();
    Field[] dataReporterFields = dataReporterClass.getDeclaredFields();
    Collect.ChangeType changeType = jp.getSignature().getName().startsWith("add") ? ChangeType.COLLECTION_ADD : ChangeType.COLLECTION_REMOVE;

    if (jp.getSignature().getName().startsWith("remove") && !(result instanceof Boolean)){
        arg = result;
    }

    try {
        for (Field field : dataReporterFields) {
            field.setAccessible(true);
            if (field.get(reporter) == targetCollection){
                Report newsAnnotation = field.getAnnotation(Report.class);
                if (newsAnnotation != null){
                    if (newsAnnotation.interval() == 0){
                        Set<Object> set = aspectOf.collectors.get(newsAnnotation.value());
                        if (set != null){
                            for (Object collector : set) {
                                handleData(newsAnnotation.value(), arg, collector, reporter, changeType);
                            }
                        }
                    }
                }
            }
        }
    } catch (IllegalAccessException e){
        throw new RuntimeException(e);
    }
}

public static Boot init(String name) {
    final Config defaultConf = ConfigFactory.load();

    final Config conf;
    final File confFile = new File(name + ".conf");
    if(confFile.exists()) {
        conf = ConfigFactory.parseFile(confFile).withFallback(defaultConf);
    } else {
        conf = defaultConf;
    }

    final Config appConfig = conf.getConfig("publisher." + name);

    final ActorSystem actorSystem = ActorSystem.create(name, appConfig);

    final ActorRef monitor;
    if(Aspects.hasAspect(MonitorAspect.class)) {
        monitor = actorSystem.actorOf(Monitor.props(), "monitor");

        MonitorAspect monitorAspect = Aspects.aspectOf(MonitorAspect.class);
        monitorAspect.setMonitor(monitor);
    } else {
        monitor = null;
    }

    return new Boot(appConfig, actorSystem, monitor);
}

@Before
public void setUp() {
    MockitoAnnotations.initMocks(this);
    when(transactionManager
            .getTransaction(new DefaultTransactionDefinition()))
            .thenReturn(status1).thenReturn(status2);
    testService = new TestService();
    Aspects.aspectOf(AnnotationDrivenTransactionManagementAspect.class)
            .setTransactionManager(transactionManager);
}

@Before
  public void dataBaseSetUp() throws Exception {
      this.simpleJdbcTemplate.update("insert into prd_identifier_types(identifier_t, name, format, private, modifiable, notifiable, deleted, description) values(null, 'NETID', 'format', false, false, true, false, 'description')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types(id, data_type, description) values(1, 'NAME', 'FORMAL')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(2, 'TERMINATION', 'UNSPECIFIED')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(3, 'FOO', 'Foo Description')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(4, 'TERMINATION', 'FIRED')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(5, 'SPONSOR', 'PERSON')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(6, 'AFFILIATION', 'STAFF')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(7, 'AFFILIATION', 'STUDENT')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(8, 'AFFILIATION', 'FACULTY')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(9, 'ADDRESS', 'HOME')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(10, 'ADDRESS', 'OFFICE')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(11, 'PHONE', 'LANDLINE')");
      this.simpleJdbcTemplate.update("insert into ctx_data_types (id, data_type, description) values(12, 'PHONE', 'CELL')");
      this.simpleJdbcTemplate.update("insert into prd_campuses(id, code, name) values(1, 'cam', 'Busch')");
      this.simpleJdbcTemplate.update("insert into ctd_countries(id, code, name) values(1, 'US', 'USA')");
      this.simpleJdbcTemplate.update("insert into drd_organizational_units(id, campus_id, organizational_unit_t, code, name) values(1, 1, 3, 'cod', 'Department')");
      this.simpleJdbcTemplate.update("insert into drd_organizational_units(id, campus_id, organizational_unit_t, code, name) values(2, 1, 3, 'fish', 'Department')");
      this.simpleJdbcTemplate.update("insert into prd_system_of_record(id, sor_id) values(1, 'test')");

// create two more SoRs
      simpleJdbcTemplate.update("insert into prd_system_of_record(id, sor_id) values(1000, '"+SOR_ID1+"')");
      simpleJdbcTemplate.update("insert into prd_system_of_record(id, sor_id) values(2000, '"+SOR_ID2+"')");

      final SoRSpecificationThreadLocalAspect aspect = Aspects.aspectOf(SoRSpecificationThreadLocalAspect.class);
      aspect.setSystemOfRecordRepository(new MockSystemOfRecordRepository());

      System.out.println("Test:@@@@@@@@@@@@@@@@@@@@@@@@@@@");
  }

@Bean
public PollableAspect getPollableAspect() {
    return Aspects.aspectOf(PollableAspect.class);
}

@Bean
RunAsAspect getRunAsAspect() {
    return Aspects.aspectOf(RunAsAspect.class);
}

@Bean
public JsonRawStringAspect getJsonRawStringAspect() {
    return Aspects.aspectOf(JsonRawStringAspect.class);
}

/**
 * Makes the aspect a Spring bean, eligible for receiving autowired components.
 */
@Bean
public HystrixAspect hystrixAspect() {
    HystrixAspect aspect = Aspects.aspectOf(HystrixAspect.class);
    return aspect;
}

private void registerEntityWithPersistenceContext(Object entity) {
    Aspects.aspectOf(BeanListenerAspect.class).register(entity, this);
}

private void deregisterEntityFromPersistenceContext(Object entity) {
    Aspects.aspectOf(BeanListenerAspect.class).deregister(entity);
}

@Before
public void setUp() throws Exception {
    MyAspectJTestAspect aspect = Aspects.aspectOf(MyAspectJTestAspect.class);
    aspect.setOpenMon(openMon);
}

@Before
public void setUp() throws Exception {
    MyAutomonTestAspect aspect = Aspects.aspectOf(MyAutomonTestAspect.class);
    aspect.setOpenMon(openMon);
}

@Before
public void setUp() throws Exception {
    MyJamonTestAspect aspect = Aspects.aspectOf(MyJamonTestAspect.class);
    aspect.setOpenMon(openMon);
}

@Before
public void setUp() throws Exception {
    MyMetricsTestAspect aspect = Aspects.aspectOf(MyMetricsTestAspect.class);
    aspect.setOpenMon(openMon);
}

@Before
public void setUp() throws Exception {
    MyJavaSimonTestAspect aspect = Aspects.aspectOf(MyJavaSimonTestAspect.class);
    aspect.setOpenMon(openMon);
}

@Bean
public MongoDocumentBacking mongoDocumentBacking(MongoChangeSetPersister mongoChangeSetPersister) throws Exception {
    MongoDocumentBacking mdb = Aspects.aspectOf(MongoDocumentBacking.class);
    mdb.setChangeSetPersister(mongoChangeSetPersister);
    return mdb;
}

@Before
public void setUp() {
    MockitoAnnotations.initMocks(this);
    Aspects.aspectOf(SystemHealthMonitor.class).heartBeatListener = mockListener;
}

@Before
public void setUp() {
    MockitoAnnotations.initMocks(this);
    Aspects.aspectOf(SystemHealthMonitor.class).heartBeatListener = mockListener;
}