import org.apache.ignite.resources.LoggerResource; //导入依赖的package包/类
/**
 * Test that closure gets right log category injected on all nodes using field injection.
 *
 * @throws Exception If failed.
 */
public void testClosureField() throws Exception {
    Ignite ignite = grid(0);

    ignite.compute().call(new IgniteCallable<Object>() {
        @LoggerResource(categoryClass = GridLoggerInjectionSelfTest.class)
        private IgniteLogger log;

        @Override public Object call() throws Exception {
            if (log instanceof GridLoggerProxy) {
                Object category = U.field(log,  "ctgr");

                assertTrue("Logger created for the wrong category.",
                    category.toString().contains(GridLoggerInjectionSelfTest.class.getName()));
            }
            else
                fail("This test should be run with proxy logger.");

            return null;
        }
    });
}
 

import org.apache.ignite.resources.LoggerResource; //导入依赖的package包/类
/**
 * @param ann Annotation.
 * @param target Target.
 * @return Logger.
 */
@SuppressWarnings("IfMayBeConditional")
private IgniteLogger resource(LoggerResource ann, Object target) {
    Class<?> cls = ann.categoryClass();
    String cat = ann.categoryName();

    IgniteLogger rsrc = getResource();

    if (cls != null && cls != Void.class)
        rsrc = rsrc.getLogger(cls);
    else if (cat != null && !cat.isEmpty())
        rsrc = rsrc.getLogger(cat);
    else
        rsrc = rsrc.getLogger(target.getClass());

    return rsrc;
}
 

import org.apache.ignite.resources.LoggerResource; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) {
    Collection<ComputeJob> jobs = new ArrayList<>(JOB_COUNT);

    for (int i = 0; i < JOB_COUNT; i++) {
        jobs.add(new ComputeJobAdapter(i) {
            @LoggerResource
            private IgniteLogger log;

            @Override public Serializable execute() {
                if (log.isInfoEnabled())
                    log.info("Executing job [index=" + argument(0) + ']');

                return argument(0);
            }
        });
    }

    return jobs;
}
 

import org.apache.ignite.resources.LoggerResource; //导入依赖的package包/类
/**
 * @param target Target spi.
 * @throws IgniteCheckedException If injection failed.
 */
private void injectLogger(IgniteSpi target) throws IgniteCheckedException {
    ctx.resource().injectBasicResource(
        target,
        LoggerResource.class,
        ctx.config().getGridLogger().getLogger(target.getClass())
    );
}
 

import org.apache.ignite.resources.LoggerResource; //导入依赖的package包/类
/**
 * @param log Logger.
 */
@LoggerResource
public void setLoggerResource(IgniteLogger log) {
    assert log != null;

    checkSet();

    infoSet.set(ResourceType.LOGGER, true);

    this.log = log;
}
 

import org.apache.ignite.resources.LoggerResource; //导入依赖的package包/类
/** {@inheritDoc} */
@Override protected Collection<? extends ComputeJob> split(int gridSize, Void arg) {
    return F.asSet(new ComputeJobAdapter() {
        /** */
        @LoggerResource
        private IgniteLogger log;

        /** */
        @IgniteInstanceResource
        private Ignite g;

        /** {@inheritDoc} */
        @Override public Object execute() {
            log.info("Executing job on node: " + g.cluster().localNode().id());

            try {
                Thread.sleep(5000);
            }
            catch (InterruptedException ignored) {
                log.info("Job thread has been interrupted.");

                Thread.currentThread().interrupt();
            }

            return null;
        }
    });
}
 

import org.apache.ignite.resources.LoggerResource; //导入依赖的package包/类
/** {@inheritDoc} */
@Override public void inject(GridResourceField field, Object target, Class<?> depCls, GridDeployment dep)
    throws IgniteCheckedException {
    GridResourceUtils.inject(field.getField(), target, resource((LoggerResource)field.getAnnotation(), target));
}