iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ (#11209) 

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ - add tests

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ - add tests

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ - add tests

* BAEL-5061 Joinpoint vs. ProceedingJoinPoint in AspectJ - add tests

Co-authored-by: majewsk6 <krzysztof.majewski.km1@contractors.roche.com>
This commit is contained in:
Krzysztof Majewski 2021-09-13 17:18:32 +02:00 committed by GitHub
parent 8fc8af79bf
commit 141a837679
10 changed files with 405 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
spring-aop/src/main/java/com/baeldung/joinpoint/ArticleService.java Normal file
View File

@ -0,0 +1,32 @@
package com.baeldung.joinpoint;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import java.util.Arrays;
import java.util.List;
import static java.util.stream.Collectors.toList;
@Service
public class ArticleService {
public List<String> getArticleList() {
return Arrays.asList(
"Article 1",
"Article 2"
);
}
public List<String> getArticleList(String startsWithFilter) {
if (StringUtils.isBlank(startsWithFilter)) {
throw new IllegalArgumentException("startsWithFilter can't be blank");
}
return getArticleList()
.stream()
.filter(a -> a.startsWith(startsWithFilter))
.collect(toList());
}
}

27
spring-aop/src/main/java/com/baeldung/joinpoint/JoinPointAfterThrowingAspect.java Normal file
View File

@ -0,0 +1,27 @@
package com.baeldung.joinpoint;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import java.util.logging.Logger;
@Aspect
@Component
public class JoinPointAfterThrowingAspect {
private static final java.util.logging.Logger log = Logger.getLogger(JoinPointAfterThrowingAspect.class.getName());
@Pointcut("execution(* com.baeldung.joinpoint.ArticleService.getArticleList(..))")
public void articleListPointcut() { }
@AfterThrowing(
pointcut = "articleListPointcut()",
throwing = "e"
)
public void logExceptions(JoinPoint jp, Exception e) {
log.severe(e.getMessage());
}
}

30
spring-aop/src/main/java/com/baeldung/joinpoint/JoinPointAroundCacheAspect.java Normal file
View File

@ -0,0 +1,30 @@
package com.baeldung.joinpoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;
@Aspect
@Component
public class JoinPointAroundCacheAspect {
public final static Map<Object, Object> CACHE = new HashMap<>();
@Pointcut("execution(* com.baeldung.joinpoint.ArticleService.getArticleList(..))")
public void articleListPointcut() { }
@Around("articleListPointcut()")
public Object aroundAdviceCache(ProceedingJoinPoint pjp) throws Throwable {
Object articles = CACHE.get(pjp.getArgs());
if (articles == null) {
articles = pjp.proceed(pjp.getArgs());
CACHE.put(pjp.getArgs(), articles);
}
return articles;
}
}

30
spring-aop/src/main/java/com/baeldung/joinpoint/JoinPointAroundExceptionAspect.java Normal file
View File

@ -0,0 +1,30 @@
package com.baeldung.joinpoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import java.util.logging.Logger;
@Aspect
@Component
public class JoinPointAroundExceptionAspect {
private static final java.util.logging.Logger log = Logger.getLogger(JoinPointAroundExceptionAspect.class.getName());
@Pointcut("execution(* com.baeldung.joinpoint.ArticleService.getArticleList(..))")
public void articleListPointcut() { }
@Around("articleListPointcut()")
public Object aroundAdviceException(ProceedingJoinPoint pjp) throws Throwable {
try {
return pjp.proceed(pjp.getArgs());
} catch (Throwable e) {
log.severe(e.getMessage());
log.info("Retrying operation");
return pjp.proceed(pjp.getArgs());
}
}
}

32
spring-aop/src/main/java/com/baeldung/joinpoint/JoinPointBeforeAspect.java Normal file
View File

@ -0,0 +1,32 @@
package com.baeldung.joinpoint;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import java.util.Arrays;
import java.util.logging.Logger;
import static java.lang.String.format;
@Aspect
@Component
public class JoinPointBeforeAspect {
private static final Logger log = Logger.getLogger(JoinPointBeforeAspect.class.getName());
@Pointcut("execution(* com.baeldung.joinpoint.ArticleService.getArticleList(..))")
public void articleListPointcut() { }
@Before("articleListPointcut()")
public void beforeAdvice(JoinPoint joinPoint) {
log.info(
format("Method %s executed with %s arguments",
joinPoint.getStaticPart().getSignature(),
Arrays.toString(joinPoint.getArgs())
)
);
}
}

39
spring-aop/src/test/java/com/baeldung/joinpoint/ArticleServiceIntegrationTest.java Normal file
View File

@ -0,0 +1,39 @@
package com.baeldung.joinpoint;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.List;
import static org.junit.Assert.assertFalse;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class ArticleServiceIntegrationTest {
@Autowired
private ArticleService articleService;
@Test
public void shouldGetNotEmptyArticleList() {
List<String> articleList = articleService.getArticleList();
assertFalse(articleList.isEmpty());
}
@Test
public void shouldGetNotEmptyArticleListWithStartsWithFilter() {
List<String> articleList = articleService.getArticleList("Article");
assertFalse(articleList.isEmpty());
}
@Test(expected = IllegalArgumentException.class)
public void shouldThrowExceptionIfStartsWithFilterIsBlank() {
articleService.getArticleList(" ");
}
}

60
spring-aop/src/test/java/com/baeldung/joinpoint/JoinPointAfterThrowingAspectIntegrationTest.java Normal file
View File

@ -0,0 +1,60 @@
package com.baeldung.joinpoint;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Handler;
import java.util.logging.LogRecord;
import java.util.logging.Logger;
import static org.hamcrest.Matchers.hasSize;
import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
@EnableAspectJAutoProxy
public class JoinPointAfterThrowingAspectIntegrationTest {
private final List<String> messages = new ArrayList<>();
@Before
public void setUp() {
Handler logEventHandler = new Handler() {
@Override
public void publish(LogRecord record) {
messages.add(record.getLevel().getName() + " " + record.getMessage());
}
@Override
public void flush() {
}
@Override
public void close() throws SecurityException {
}
};
Logger logger = Logger.getLogger(JoinPointAfterThrowingAspect.class.getName());
logger.addHandler(logEventHandler);
}
@Autowired
private ArticleService articleService;
@Test(expected = IllegalArgumentException.class)
public void shouldLogMethodSignatureBeforeExecution() {
articleService.getArticleList(" ");
assertThat(messages, hasSize(1));
assertTrue(messages.contains("SEVERE startsWithFilter can't be blank"));
}
}

35
spring-aop/src/test/java/com/baeldung/joinpoint/JoinPointAroundCacheAspectIntegrationTest.java Normal file
View File

@ -0,0 +1,35 @@
package com.baeldung.joinpoint;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.List;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
@EnableAspectJAutoProxy
public class JoinPointAroundCacheAspectIntegrationTest {
@Autowired
private ArticleService articleService;
@Test
public void shouldPopulateCache() {
assertTrue(JoinPointAroundCacheAspect.CACHE.isEmpty());
List<String> articles = articleService.getArticleList();
assertFalse(JoinPointAroundCacheAspect.CACHE.isEmpty());
assertEquals(JoinPointAroundCacheAspect.CACHE.size(), 1);
assertEquals(JoinPointAroundCacheAspect.CACHE.values().iterator().next(), articles);
}
}

60
spring-aop/src/test/java/com/baeldung/joinpoint/JoinPointAroundExceptionAspectIntegrationTest.java Normal file
View File

@ -0,0 +1,60 @@
package com.baeldung.joinpoint;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Handler;
import java.util.logging.LogRecord;
import java.util.logging.Logger;
import static org.hamcrest.Matchers.hasSize;
import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
@EnableAspectJAutoProxy
public class JoinPointAroundExceptionAspectIntegrationTest {
private final List<String> messages = new ArrayList<>();
@Before
public void setUp() {
Handler logEventHandler = new Handler() {
@Override
public void publish(LogRecord record) {
messages.add(record.getLevel().getName() + " " + record.getMessage());
}
@Override
public void flush() {
}
@Override
public void close() throws SecurityException {
}
};
Logger logger = Logger.getLogger(JoinPointAroundExceptionAspect.class.getName());
logger.addHandler(logEventHandler);
}
@Autowired
private ArticleService articleService;
@Test(expected = IllegalArgumentException.class)
public void shouldLogMethodSignatureBeforeExecution() {
articleService.getArticleList(" ");
assertThat(messages, hasSize(1));
assertTrue(messages.contains("INFO Retrying operation"));
}
}

60
spring-aop/src/test/java/com/baeldung/joinpoint/JoinPointBeforeAspectIntegrationTest.java Normal file
View File

@ -0,0 +1,60 @@
package com.baeldung.joinpoint;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Handler;
import java.util.logging.LogRecord;
import java.util.logging.Logger;
import static org.hamcrest.Matchers.hasSize;
import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
@EnableAspectJAutoProxy
public class JoinPointBeforeAspectIntegrationTest {
private final List<String> messages = new ArrayList<>();
@Before
public void setUp() {
Handler logEventHandler = new Handler() {
@Override
public void publish(LogRecord record) {
messages.add(record.getLevel().getName() + " " + record.getMessage());
}
@Override
public void flush() {
}
@Override
public void close() throws SecurityException {
}
};
Logger logger = Logger.getLogger(JoinPointBeforeAspect.class.getName());
logger.addHandler(logEventHandler);
}
@Autowired
private ArticleService articleService;
@Test
public void shouldLogMethodSignatureBeforeExecution() {
articleService.getArticleList();
assertThat(messages, hasSize(1));
assertTrue(messages.contains("INFO Method List com.baeldung.joinpoint.ArticleService.getArticleList() executed with [] arguments"));
}
}